LICENSE
README.md
pyproject.toml
flowforge/__init__.py
flowforge/audit.py
flowforge/celery_app.py
flowforge/cli.py
flowforge/crypto.py
flowforge/tasks.py
flowforge/api/__init__.py
flowforge/api/app.py
flowforge/api/auth.py
flowforge/api/serializers.py
flowforge/api/validators.py
flowforge/api/routes/__init__.py
flowforge/api/routes/ai.py
flowforge/api/routes/audit.py
flowforge/api/routes/auth.py
flowforge/api/routes/bulk_loads.py
flowforge/api/routes/connections.py
flowforge/api/routes/emails.py
flowforge/api/routes/metrics.py
flowforge/api/routes/mfa.py
flowforge/api/routes/password_reset.py
flowforge/api/routes/pipelines.py
flowforge/api/routes/projects.py
flowforge/api/routes/providers.py
flowforge/api/routes/recipients.py
flowforge/api/routes/reports.py
flowforge/api/routes/runs.py
flowforge/api/routes/setup.py
flowforge/api/routes/sso.py
flowforge/api/routes/steps.py
flowforge/api/routes/users.py
flowforge/connections/__init__.py
flowforge/connections/base.py
flowforge/connections/factory.py
flowforge/connections/mssql.py
flowforge/connections/mysql.py
flowforge/connections/odbc.py
flowforge/connections/oracle.py
flowforge/connections/postgres.py
flowforge/connections/ssh.py
flowforge/db/__init__.py
flowforge/db/models.py
flowforge/db/migrations/__init__.py
flowforge/db/migrations/env.py
flowforge/db/migrations/versions/0001_baseline.py
flowforge/db/migrations/versions/0002_timezone_timestamps.py
flowforge/db/migrations/versions/0003_indexes_and_constraints.py
flowforge/db/migrations/versions/0004_json_report_format.py
flowforge/db/migrations/versions/0005_bulk_load_configs.py
flowforge/db/migrations/versions/0006_projects.py
flowforge/db/migrations/versions/0007_pipeline_variables_index.py
flowforge/db/migrations/versions/0008_token_blocklist.py
flowforge/db/migrations/versions/0009_narrow_db_type_constraint.py
flowforge/db/migrations/versions/0010_webhook_tokens.py
flowforge/db/migrations/versions/0011_fix_step_type_constraint.py
flowforge/db/migrations/versions/0012_onedrive_support.py
flowforge/db/migrations/versions/0013_ai_analyze_step.py
flowforge/db/migrations/versions/0014_sftp_transfer_step.py
flowforge/db/migrations/versions/0015_datetime_timezone.py
flowforge/db/migrations/versions/0016_pipeline_failure_webhook.py
flowforge/db/migrations/versions/0017_mysql_connection_type.py
flowforge/db/migrations/versions/0018_user_role.py
flowforge/db/migrations/versions/0019_backfill_admin_role.py
flowforge/db/migrations/versions/0020_mfa_sso.py
flowforge/db/migrations/versions/0021_mssql_odbc_pwreset.py
flowforge/db/migrations/versions/0023_pipeline_deps_parallel.py
flowforge/db/migrations/versions/0024_report_column_formatting.py
flowforge/db/migrations/versions/0025_new_providers_notification.py
flowforge/db/migrations/versions/6158f44dafca_add_auditlog_model.py
flowforge/db/migrations/versions/9c08f36f9ef8_add_send_only_on_failure_to_ff_pipelines.py
flowforge/db/migrations/versions/__init__.py
flowforge/db/migrations/versions/b7a76582c1ea_add_sshconnection_and_update_step_type_.py
flowforge/db/migrations/versions/c4e8f2a1b9d3_add_ssh_health_check_step_type.py
flowforge/email_providers/__init__.py
flowforge/email_providers/base.py
flowforge/email_providers/factory.py
flowforge/email_providers/gmail.py
flowforge/email_providers/mailgun.py
flowforge/email_providers/microsoft365.py
flowforge/email_providers/sendgrid.py
flowforge/email_providers/ses.py
flowforge/email_providers/smtp.py
flowforge/engine/__init__.py
flowforge/engine/cleanup.py
flowforge/engine/context.py
flowforge/engine/launcher.py
flowforge/engine/loader.py
flowforge/engine/runner.py
flowforge/engine/scheduler.py
flowforge/engine/shutdown.py
flowforge/reports/__init__.py
flowforge/reports/csv_report.py
flowforge/reports/excel_report.py
flowforge/reports/health_report.py
flowforge/reports/json_report.py
flowforge/reports/pdf_report.py
flowforge/steps/__init__.py
flowforge/steps/ai_analyze.py
flowforge/steps/base.py
flowforge/steps/bulk_load.py
flowforge/steps/data_load.py
flowforge/steps/db_health_check.py
flowforge/steps/db_procedure.py
flowforge/steps/db_query.py
flowforge/steps/drive_upload.py
flowforge/steps/email_step.py
flowforge/steps/notification.py
flowforge/steps/onedrive_upload.py
flowforge/steps/report.py
flowforge/steps/script_report.py
flowforge/steps/sftp_transfer.py
flowforge/steps/ssh_command.py
flowforge/steps/ssh_health_check.py
flowforge/storage/__init__.py
flowforge/storage/google_drive.py
flowforge/storage/onedrive.py
flowforge_io.egg-info/PKG-INFO
flowforge_io.egg-info/SOURCES.txt
flowforge_io.egg-info/dependency_links.txt
flowforge_io.egg-info/entry_points.txt
flowforge_io.egg-info/requires.txt
flowforge_io.egg-info/top_level.txt
tests/test_ai.py
tests/test_ai_analyze.py
tests/test_app_coverage.py
tests/test_audit.py
tests/test_audit_routes.py
tests/test_auth.py
tests/test_auth_coverage.py
tests/test_bulk_load_configs.py
tests/test_bulk_load_step.py
tests/test_bulk_loads_coverage.py
tests/test_cleanup.py
tests/test_connections.py
tests/test_connections_coverage.py
tests/test_connections_factory.py
tests/test_connections_factory_coverage.py
tests/test_connections_mssql_odbc.py
tests/test_context.py
tests/test_cron_endpoint.py
tests/test_crypto.py
tests/test_crypto_file_encryption.py
tests/test_data_load_create.py
tests/test_data_load_step.py
tests/test_db_health_check.py
tests/test_db_health_check_coverage.py
tests/test_db_procedure_unit.py
tests/test_db_query_capture.py
tests/test_drive_upload_step.py
tests/test_email_configs.py
tests/test_email_providers.py
tests/test_email_providers_ses_sg_mg.py
tests/test_email_providers_unit.py
tests/test_email_step_coverage.py
tests/test_email_step_unit.py
tests/test_emails_coverage.py
tests/test_excel_report_coverage.py
tests/test_jinja_errors.py
tests/test_jwt_expiry.py
tests/test_launcher_extended.py
tests/test_launcher_unit.py
tests/test_loader_unit.py
tests/test_metrics_coverage.py
tests/test_mfa.py
tests/test_mysql.py
tests/test_mysql_extended.py
tests/test_notification_step.py
tests/test_onedrive.py
tests/test_oracle.py
tests/test_oracle_bulk_load.py
tests/test_password_reset.py
tests/test_pipeline_variables.py
tests/test_pipelines.py
tests/test_pipelines_extended_coverage.py
tests/test_postgres_unit.py
tests/test_projects.py
tests/test_providers_extended.py
tests/test_rbac.py
tests/test_recipients.py
tests/test_report_e2e.py
tests/test_report_generators.py
tests/test_report_step_coverage.py
tests/test_reports.py
tests/test_runner.py
tests/test_runner_extended.py
tests/test_runs.py
tests/test_runs_api.py
tests/test_runs_extended.py
tests/test_scheduler.py
tests/test_scheduler_prune.py
tests/test_script_report.py
tests/test_serializers.py
tests/test_setup_extended.py
tests/test_sftp.py
tests/test_shutdown.py
tests/test_shutdown_cancel_runs.py
tests/test_smart_attachments.py
tests/test_smtp_test_method.py
tests/test_ssh_command.py
tests/test_ssh_connection_unit.py
tests/test_ssh_health_check.py
tests/test_sso.py
tests/test_steps_db.py
tests/test_steps_extended.py
tests/test_users.py
tests/test_validators.py
tests/test_webhook.py