apache / airflow

Compare 9066f14 ... +12 ... d93a36a

Coverage Reach
providers/google/cloud/operators/dataproc.py providers/google/cloud/operators/dlp.py providers/google/cloud/operators/bigquery.py providers/google/cloud/operators/datacatalog.py providers/google/cloud/operators/mlengine.py providers/google/cloud/operators/cloud_memorystore.py providers/google/cloud/operators/vision.py providers/google/cloud/operators/cloud_storage_transfer_service.py providers/google/cloud/operators/automl.py providers/google/cloud/operators/gcs.py providers/google/cloud/operators/tasks.py providers/google/cloud/operators/cloud_sql.py providers/google/cloud/operators/dataflow.py providers/google/cloud/operators/datafusion.py providers/google/cloud/operators/stackdriver.py providers/google/cloud/operators/workflows.py providers/google/cloud/operators/bigtable.py providers/google/cloud/operators/spanner.py providers/google/cloud/operators/pubsub.py providers/google/cloud/operators/functions.py providers/google/cloud/operators/datastore.py providers/google/cloud/operators/compute.py providers/google/cloud/operators/cloud_build.py providers/google/cloud/operators/natural_language.py providers/google/cloud/operators/kubernetes_engine.py providers/google/cloud/operators/video_intelligence.py providers/google/cloud/operators/bigquery_dts.py providers/google/cloud/operators/translate_speech.py providers/google/cloud/operators/dataprep.py providers/google/cloud/operators/text_to_speech.py providers/google/cloud/operators/speech_to_text.py providers/google/cloud/operators/translate.py providers/google/cloud/operators/life_sciences.py providers/google/cloud/hooks/bigquery.py providers/google/cloud/hooks/gcs.py providers/google/cloud/hooks/cloud_sql.py providers/google/cloud/hooks/dataflow.py providers/google/cloud/hooks/dlp.py providers/google/cloud/hooks/datacatalog.py providers/google/cloud/hooks/vision.py providers/google/cloud/hooks/cloud_memorystore.py providers/google/cloud/hooks/mlengine.py providers/google/cloud/hooks/cloud_storage_transfer_service.py providers/google/cloud/hooks/dataproc.py providers/google/cloud/hooks/compute_ssh.py providers/google/cloud/hooks/pubsub.py providers/google/cloud/hooks/datafusion.py providers/google/cloud/hooks/stackdriver.py providers/google/cloud/hooks/spanner.py providers/google/cloud/hooks/compute.py providers/google/cloud/hooks/tasks.py providers/google/cloud/hooks/automl.py providers/google/cloud/hooks/datastore.py providers/google/cloud/hooks/bigtable.py providers/google/cloud/hooks/kubernetes_engine.py providers/google/cloud/hooks/workflows.py providers/google/cloud/hooks/functions.py providers/google/cloud/hooks/dataprep.py providers/google/cloud/hooks/bigquery_dts.py providers/google/cloud/hooks/life_sciences.py providers/google/cloud/hooks/natural_language.py providers/google/cloud/hooks/cloud_build.py providers/google/cloud/hooks/gdm.py providers/google/cloud/hooks/kms.py providers/google/cloud/hooks/speech_to_text.py providers/google/cloud/hooks/video_intelligence.py providers/google/cloud/hooks/text_to_speech.py providers/google/cloud/hooks/os_login.py providers/google/cloud/hooks/translate.py providers/google/cloud/hooks/secret_manager.py providers/google/cloud/example_dags/example_datacatalog.py providers/google/cloud/example_dags/example_vision.py providers/google/cloud/example_dags/example_gcs.py providers/google/cloud/example_dags/example_cloud_memorystore.py providers/google/cloud/example_dags/example_dataflow.py providers/google/cloud/example_dags/example_cloud_sql_query.py providers/google/cloud/example_dags/example_mlengine.py providers/google/cloud/example_dags/example_dataproc.py providers/google/cloud/example_dags/example_automl_tables.py providers/google/cloud/example_dags/example_cloud_sql.py providers/google/cloud/example_dags/example_bigtable.py providers/google/cloud/example_dags/example_bigquery_operations.py providers/google/cloud/example_dags/example_dlp.py providers/google/cloud/example_dags/example_bigquery_queries.py providers/google/cloud/example_dags/example_tasks.py providers/google/cloud/example_dags/example_workflows.py providers/google/cloud/example_dags/example_presto_to_gcs.py providers/google/cloud/example_dags/example_trino_to_gcs.py providers/google/cloud/example_dags/example_datafusion.py providers/google/cloud/example_dags/example_functions.py providers/google/cloud/example_dags/example_pubsub.py providers/google/cloud/example_dags/example_cloud_storage_transfer_service_aws.py providers/google/cloud/example_dags/example_salesforce_to_gcs.py providers/google/cloud/example_dags/example_stackdriver.py providers/google/cloud/example_dags/example_gcs_to_sftp.py providers/google/cloud/example_dags/example_facebook_ads_to_gcs.py providers/google/cloud/example_dags/example_bigquery_sensors.py providers/google/cloud/example_dags/example_spanner.py providers/google/cloud/example_dags/example_datastore.py providers/google/cloud/example_dags/example_gcs_to_gcs.py providers/google/cloud/example_dags/example_automl_nl_text_classification.py providers/google/cloud/example_dags/example_automl_translation.py providers/google/cloud/example_dags/example_cloud_build.py providers/google/cloud/example_dags/example_automl_video_intelligence_tracking.py providers/google/cloud/example_dags/example_automl_nl_text_extraction.py providers/google/cloud/example_dags/example_automl_nl_text_sentiment.py providers/google/cloud/example_dags/example_automl_vision_object_detection.py providers/google/cloud/example_dags/example_automl_vision_classification.py providers/google/cloud/example_dags/example_s3_to_gcs.py providers/google/cloud/example_dags/example_automl_video_intelligence_classification.py providers/google/cloud/example_dags/example_natural_language.py providers/google/cloud/example_dags/example_cloud_storage_transfer_service_gcp.py providers/google/cloud/example_dags/example_translate_speech.py providers/google/cloud/example_dags/example_compute_igm.py providers/google/cloud/example_dags/example_bigquery_dts.py providers/google/cloud/example_dags/example_bigquery_transfer.py providers/google/cloud/example_dags/example_kubernetes_engine.py providers/google/cloud/example_dags/example_video_intelligence.py providers/google/cloud/example_dags/example_compute.py providers/google/cloud/example_dags/example_gcs_timespan_file_transform.py providers/google/cloud/example_dags/example_bigquery_to_bigquery.py providers/google/cloud/example_dags/example_sftp_to_gcs.py providers/google/cloud/example_dags/example_speech_to_text.py providers/google/cloud/example_dags/example_bigquery_to_gcs.py providers/google/cloud/example_dags/example_compute_ssh.py providers/google/cloud/example_dags/example_life_sciences.py providers/google/cloud/example_dags/example_dataflow_flex_template.py providers/google/cloud/example_dags/example_dataprep.py providers/google/cloud/example_dags/example_text_to_speech.py providers/google/cloud/example_dags/example_gcs_to_bigquery.py providers/google/cloud/example_dags/example_gdrive_to_gcs.py providers/google/cloud/example_dags/example_dataflow_sql.py providers/google/cloud/example_dags/example_gdrive_to_local.py providers/google/cloud/example_dags/example_postgres_to_gcs.py providers/google/cloud/example_dags/example_gcs_to_local.py providers/google/cloud/example_dags/example_azure_fileshare_to_gcs.py providers/google/cloud/example_dags/example_mysql_to_gcs.py providers/google/cloud/example_dags/example_oracle_to_gcs.py providers/google/cloud/example_dags/example_translate.py providers/google/cloud/example_dags/example_local_to_gcs.py providers/google/cloud/example_dags/example_sheets_to_gcs.py providers/google/cloud/transfers/cassandra_to_gcs.py providers/google/cloud/transfers/sql_to_gcs.py providers/google/cloud/transfers/gcs_to_gcs.py providers/google/cloud/transfers/presto_to_gcs.py providers/google/cloud/transfers/trino_to_gcs.py providers/google/cloud/transfers/gcs_to_bigquery.py providers/google/cloud/transfers/postgres_to_gcs.py providers/google/cloud/transfers/gcs_to_sftp.py providers/google/cloud/transfers/s3_to_gcs.py providers/google/cloud/transfers/sftp_to_gcs.py providers/google/cloud/transfers/azure_fileshare_to_gcs.py providers/google/cloud/transfers/mysql_to_gcs.py providers/google/cloud/transfers/bigquery_to_mysql.py providers/google/cloud/transfers/oracle_to_gcs.py providers/google/cloud/transfers/adls_to_gcs.py providers/google/cloud/transfers/gcs_to_local.py providers/google/cloud/transfers/sheets_to_gcs.py providers/google/cloud/transfers/bigquery_to_gcs.py providers/google/cloud/transfers/facebook_ads_to_gcs.py providers/google/cloud/transfers/salesforce_to_gcs.py providers/google/cloud/transfers/local_to_gcs.py providers/google/cloud/transfers/bigquery_to_bigquery.py providers/google/cloud/transfers/gdrive_to_gcs.py providers/google/cloud/transfers/mssql_to_gcs.py providers/google/cloud/transfers/gdrive_to_local.py providers/google/cloud/sensors/gcs.py providers/google/cloud/sensors/dataflow.py providers/google/cloud/sensors/bigtable.py providers/google/cloud/sensors/pubsub.py providers/google/cloud/sensors/bigquery.py providers/google/cloud/sensors/bigquery_dts.py providers/google/cloud/sensors/workflows.py providers/google/cloud/sensors/dataproc.py providers/google/cloud/sensors/cloud_storage_transfer_service.py providers/google/cloud/utils/credentials_provider.py providers/google/cloud/utils/field_validator.py providers/google/cloud/utils/mlengine_operator_utils.py providers/google/cloud/utils/field_sanitizer.py providers/google/cloud/utils/mlengine_prediction_summary.py providers/google/cloud/log/stackdriver_task_handler.py providers/google/cloud/log/gcs_task_handler.py providers/google/cloud/secrets/secret_manager.py providers/google/cloud/_internal_client/secret_manager_client.py providers/google/marketing_platform/operators/display_video.py providers/google/marketing_platform/operators/campaign_manager.py providers/google/marketing_platform/operators/analytics.py providers/google/marketing_platform/operators/search_ads.py providers/google/marketing_platform/hooks/campaign_manager.py providers/google/marketing_platform/hooks/analytics.py providers/google/marketing_platform/hooks/display_video.py providers/google/marketing_platform/hooks/search_ads.py providers/google/marketing_platform/example_dags/example_display_video.py providers/google/marketing_platform/example_dags/example_campaign_manager.py providers/google/marketing_platform/example_dags/example_analytics.py providers/google/marketing_platform/example_dags/example_search_ads.py providers/google/marketing_platform/sensors/display_video.py providers/google/marketing_platform/sensors/campaign_manager.py providers/google/marketing_platform/sensors/search_ads.py providers/google/common/hooks/base_google.py providers/google/common/hooks/discovery_api.py providers/google/common/utils/id_token_credentials.py providers/google/common/auth_backend/google_openid.py providers/google/suite/hooks/drive.py providers/google/suite/hooks/sheets.py providers/google/suite/transfers/gcs_to_gdrive.py providers/google/suite/transfers/gcs_to_sheets.py providers/google/suite/example_dags/example_sheets.py providers/google/suite/example_dags/example_gcs_to_sheets.py providers/google/suite/example_dags/example_gcs_to_gdrive.py providers/google/suite/sensors/drive.py providers/google/suite/operators/sheets.py providers/google/ads/hooks/ads.py providers/google/ads/transfers/ads_to_gcs.py providers/google/ads/operators/ads.py providers/google/ads/example_dags/example_ads.py providers/google/firebase/hooks/firestore.py providers/google/firebase/example_dags/example_firestore.py providers/google/firebase/operators/firestore.py providers/google/leveldb/hooks/leveldb.py providers/google/leveldb/operators/leveldb.py providers/google/leveldb/example_dags/example_leveldb.py providers/amazon/aws/hooks/s3.py providers/amazon/aws/hooks/sagemaker.py providers/amazon/aws/hooks/base_aws.py providers/amazon/aws/hooks/datasync.py providers/amazon/aws/hooks/batch_client.py providers/amazon/aws/hooks/elasticache_replication_group.py providers/amazon/aws/hooks/glue.py providers/amazon/aws/hooks/athena.py providers/amazon/aws/hooks/glue_crawler.py providers/amazon/aws/hooks/batch_waiters.py providers/amazon/aws/hooks/emr.py providers/amazon/aws/hooks/redshift.py providers/amazon/aws/hooks/cloud_formation.py providers/amazon/aws/hooks/logs.py providers/amazon/aws/hooks/sns.py providers/amazon/aws/hooks/glue_catalog.py providers/amazon/aws/hooks/glacier.py providers/amazon/aws/hooks/step_function.py providers/amazon/aws/hooks/dynamodb.py providers/amazon/aws/hooks/ses.py providers/amazon/aws/hooks/ec2.py providers/amazon/aws/hooks/secrets_manager.py providers/amazon/aws/hooks/lambda_function.py providers/amazon/aws/hooks/kinesis.py providers/amazon/aws/hooks/sqs.py providers/amazon/aws/operators/ecs.py providers/amazon/aws/operators/datasync.py providers/amazon/aws/operators/sagemaker_endpoint.py providers/amazon/aws/operators/athena.py providers/amazon/aws/operators/s3_file_transform.py providers/amazon/aws/operators/sagemaker_base.py providers/amazon/aws/operators/batch.py providers/amazon/aws/operators/s3_bucket_tagging.py providers/amazon/aws/operators/sagemaker_processing.py providers/amazon/aws/operators/emr_add_steps.py providers/amazon/aws/operators/glue.py providers/amazon/aws/operators/sagemaker_transform.py providers/amazon/aws/operators/sagemaker_training.py providers/amazon/aws/operators/cloud_formation.py providers/amazon/aws/operators/s3_bucket.py providers/amazon/aws/operators/emr_create_job_flow.py providers/amazon/aws/operators/glue_crawler.py providers/amazon/aws/operators/emr_modify_cluster.py providers/amazon/aws/operators/sagemaker_tuning.py providers/amazon/aws/operators/step_function_start_execution.py providers/amazon/aws/operators/s3_delete_objects.py providers/amazon/aws/operators/emr_terminate_job_flow.py providers/amazon/aws/operators/ec2_start_instance.py providers/amazon/aws/operators/ec2_stop_instance.py providers/amazon/aws/operators/sns.py providers/amazon/aws/operators/step_function_get_execution_output.py providers/amazon/aws/operators/sqs.py providers/amazon/aws/operators/sagemaker_model.py providers/amazon/aws/operators/s3_copy_object.py providers/amazon/aws/operators/s3_list.py providers/amazon/aws/operators/sagemaker_endpoint_config.py providers/amazon/aws/operators/glacier.py providers/amazon/aws/sensors/s3_key.py providers/amazon/aws/sensors/s3_keys_unchanged.py providers/amazon/aws/sensors/sagemaker_training.py providers/amazon/aws/sensors/cloud_formation.py providers/amazon/aws/sensors/emr_base.py providers/amazon/aws/sensors/sagemaker_base.py providers/amazon/aws/sensors/step_function_execution.py providers/amazon/aws/sensors/sqs.py providers/amazon/aws/sensors/athena.py providers/amazon/aws/sensors/glue_crawler.py providers/amazon/aws/sensors/glacier.py providers/amazon/aws/sensors/emr_step.py providers/amazon/aws/sensors/glue_catalog_partition.py providers/amazon/aws/sensors/emr_job_flow.py providers/amazon/aws/sensors/glue.py providers/amazon/aws/sensors/s3_prefix.py providers/amazon/aws/sensors/ec2_instance_state.py providers/amazon/aws/sensors/sagemaker_endpoint.py providers/amazon/aws/sensors/sagemaker_tuning.py providers/amazon/aws/sensors/sagemaker_transform.py providers/amazon/aws/sensors/redshift.py providers/amazon/aws/transfers/dynamodb_to_s3.py providers/amazon/aws/transfers/google_api_to_s3.py providers/amazon/aws/transfers/mysql_to_s3.py providers/amazon/aws/transfers/gcs_to_s3.py providers/amazon/aws/transfers/redshift_to_s3.py providers/amazon/aws/transfers/mongo_to_s3.py providers/amazon/aws/transfers/s3_to_redshift.py providers/amazon/aws/transfers/exasol_to_s3.py providers/amazon/aws/transfers/hive_to_dynamodb.py providers/amazon/aws/transfers/glacier_to_gcs.py providers/amazon/aws/transfers/s3_to_sftp.py providers/amazon/aws/transfers/sftp_to_s3.py providers/amazon/aws/transfers/ftp_to_s3.py providers/amazon/aws/transfers/imap_attachment_to_s3.py providers/amazon/aws/transfers/s3_to_ftp.py providers/amazon/aws/example_dags/example_google_api_to_s3_transfer_advanced.py providers/amazon/aws/example_dags/example_s3_to_redshift.py providers/amazon/aws/example_dags/example_datasync_2.py providers/amazon/aws/example_dags/example_emr_job_flow_manual_steps.py providers/amazon/aws/example_dags/example_s3_bucket.py providers/amazon/aws/example_dags/example_glacier_to_gcs.py providers/amazon/aws/example_dags/example_s3_bucket_tagging.py providers/amazon/aws/example_dags/example_emr_job_flow_automatic_steps.py providers/amazon/aws/example_dags/example_datasync_1.py providers/amazon/aws/example_dags/example_imap_attachment_to_s3.py providers/amazon/aws/example_dags/example_google_api_to_s3_transfer_basic.py providers/amazon/aws/example_dags/example_ecs_fargate.py providers/amazon/aws/log/s3_task_handler.py providers/amazon/aws/log/cloudwatch_task_handler.py providers/amazon/aws/secrets/secrets_manager.py providers/amazon/aws/secrets/systems_manager.py providers/amazon/aws/utils/redshift.py providers/amazon/aws/utils/emailer.py providers/amazon/aws/exceptions.py providers/apache/hive/hooks/hive.py providers/apache/hive/transfers/s3_to_hive.py providers/apache/hive/transfers/mysql_to_hive.py providers/apache/hive/transfers/mssql_to_hive.py providers/apache/hive/transfers/hive_to_mysql.py providers/apache/hive/transfers/vertica_to_hive.py providers/apache/hive/transfers/hive_to_samba.py providers/apache/hive/operators/hive_stats.py providers/apache/hive/operators/hive.py providers/apache/hive/sensors/named_hive_partition.py providers/apache/hive/sensors/hive_partition.py providers/apache/hive/sensors/metastore_partition.py providers/apache/hive/example_dags/example_twitter_dag.py providers/apache/spark/hooks/spark_submit.py providers/apache/spark/hooks/spark_jdbc.py providers/apache/spark/hooks/spark_sql.py providers/apache/spark/hooks/spark_jdbc_script.py providers/apache/spark/operators/spark_submit.py providers/apache/spark/operators/spark_jdbc.py providers/apache/spark/operators/spark_sql.py providers/apache/spark/example_dags/example_spark_dag.py providers/apache/beam/operators/beam.py providers/apache/beam/hooks/beam.py providers/apache/beam/example_dags/example_beam.py providers/apache/sqoop/hooks/sqoop.py providers/apache/sqoop/operators/sqoop.py providers/apache/livy/hooks/livy.py providers/apache/livy/operators/livy.py providers/apache/livy/sensors/livy.py providers/apache/livy/example_dags/example_livy.py providers/apache/hdfs/hooks/webhdfs.py providers/apache/hdfs/hooks/hdfs.py providers/apache/hdfs/sensors/hdfs.py providers/apache/hdfs/sensors/web_hdfs.py providers/apache/druid/hooks/druid.py providers/apache/druid/transfers/hive_to_druid.py providers/apache/druid/operators/druid.py providers/apache/druid/operators/druid_check.py providers/apache/pinot/hooks/pinot.py providers/apache/cassandra/hooks/cassandra.py providers/apache/cassandra/sensors/record.py providers/apache/cassandra/sensors/table.py providers/apache/cassandra/example_dags/example_cassandra_dag.py providers/apache/kylin/operators/kylin_cube.py providers/apache/kylin/hooks/kylin.py providers/apache/kylin/example_dags/example_kylin_dag.py providers/apache/pig/hooks/pig.py providers/apache/pig/operators/pig.py providers/apache/pig/example_dags/example_pig.py providers/microsoft/azure/hooks/azure_data_factory.py providers/microsoft/azure/hooks/azure_cosmos.py providers/microsoft/azure/hooks/wasb.py providers/microsoft/azure/hooks/azure_batch.py providers/microsoft/azure/hooks/adx.py providers/microsoft/azure/hooks/azure_data_lake.py providers/microsoft/azure/hooks/base_azure.py providers/microsoft/azure/hooks/azure_fileshare.py providers/microsoft/azure/hooks/azure_container_instance.py providers/microsoft/azure/hooks/azure_container_registry.py providers/microsoft/azure/hooks/azure_container_volume.py providers/microsoft/azure/operators/azure_container_instances.py providers/microsoft/azure/operators/azure_batch.py providers/microsoft/azure/operators/adx.py providers/microsoft/azure/operators/wasb_delete_blob.py providers/microsoft/azure/operators/azure_cosmos.py providers/microsoft/azure/operators/adls_delete.py providers/microsoft/azure/operators/adls_list.py providers/microsoft/azure/transfers/oracle_to_azure_data_lake.py providers/microsoft/azure/transfers/azure_blob_to_gcs.py providers/microsoft/azure/transfers/local_to_adls.py providers/microsoft/azure/transfers/file_to_wasb.py providers/microsoft/azure/example_dags/example_fileshare.py providers/microsoft/azure/example_dags/example_azure_blob_to_gcs.py providers/microsoft/azure/example_dags/example_adls_delete.py providers/microsoft/azure/example_dags/example_local_to_adls.py providers/microsoft/azure/example_dags/example_azure_cosmosdb.py providers/microsoft/azure/example_dags/example_file_to_wasb.py providers/microsoft/azure/example_dags/example_azure_container_instances.py providers/microsoft/azure/log/wasb_task_handler.py providers/microsoft/azure/secrets/azure_key_vault.py providers/microsoft/azure/sensors/wasb.py providers/microsoft/azure/sensors/azure_cosmos.py providers/microsoft/winrm/hooks/winrm.py providers/microsoft/winrm/operators/winrm.py providers/microsoft/winrm/example_dags/example_winrm.py providers/microsoft/mssql/operators/mssql.py providers/microsoft/mssql/hooks/mssql.py providers/cncf/kubernetes/operators/kubernetes_pod.py providers/cncf/kubernetes/operators/spark_kubernetes.py providers/cncf/kubernetes/utils/pod_launcher.py providers/cncf/kubernetes/utils/xcom_sidecar.py providers/cncf/kubernetes/backcompat/backwards_compat_converters.py providers/cncf/kubernetes/backcompat/pod.py providers/cncf/kubernetes/backcompat/volume.py providers/cncf/kubernetes/backcompat/volume_mount.py providers/cncf/kubernetes/backcompat/pod_runtime_info_env.py providers/cncf/kubernetes/hooks/kubernetes.py providers/cncf/kubernetes/sensors/spark_kubernetes.py providers/cncf/kubernetes/example_dags/example_kubernetes.py providers/cncf/kubernetes/example_dags/example_spark_kubernetes.py providers/qubole/hooks/qubole.py providers/qubole/hooks/qubole_check.py providers/qubole/operators/qubole.py providers/qubole/operators/qubole_check.py providers/qubole/example_dags/example_qubole.py providers/qubole/sensors/qubole.py providers/hashicorp/_internal_client/vault_client.py providers/hashicorp/hooks/vault.py providers/hashicorp/secrets/vault.py providers/docker/operators/docker.py providers/docker/operators/docker_swarm.py providers/docker/hooks/docker.py providers/docker/example_dags/example_docker_copy_data.py providers/docker/example_dags/example_docker.py providers/docker/example_dags/example_docker_swarm.py providers/mysql/transfers/vertica_to_mysql.py providers/mysql/transfers/presto_to_mysql.py providers/mysql/transfers/trino_to_mysql.py providers/mysql/transfers/s3_to_mysql.py providers/mysql/hooks/mysql.py providers/mysql/operators/mysql.py providers/mysql/example_dags/example_mysql.py providers/databricks/hooks/databricks.py providers/databricks/operators/databricks.py providers/databricks/example_dags/example_databricks.py providers/snowflake/hooks/snowflake.py providers/snowflake/transfers/snowflake_to_slack.py providers/snowflake/transfers/s3_to_snowflake.py providers/snowflake/example_dags/example_snowflake.py providers/snowflake/operators/snowflake.py providers/ssh/hooks/ssh.py providers/ssh/operators/ssh.py providers/sftp/hooks/sftp.py providers/sftp/operators/sftp.py providers/sftp/sensors/sftp.py providers/yandex/operators/yandexcloud_dataproc.py providers/yandex/hooks/yandex.py providers/yandex/hooks/yandexcloud_dataproc.py providers/yandex/example_dags/example_yandexcloud_dataproc.py providers/elasticsearch/log/es_task_handler.py providers/elasticsearch/hooks/elasticsearch.py providers/oracle/hooks/oracle.py providers/oracle/transfers/oracle_to_oracle.py providers/oracle/operators/oracle.py providers/asana/hooks/asana.py providers/asana/operators/asana_tasks.py providers/asana/example_dags/example_asana.py providers/http/hooks/http.py providers/http/operators/http.py providers/http/sensors/http.py providers/http/example_dags/example_http.py providers/imap/hooks/imap.py providers/imap/sensors/imap_attachment.py providers/slack/hooks/slack_webhook.py providers/slack/hooks/slack.py providers/slack/operators/slack.py providers/slack/operators/slack_webhook.py providers/jenkins/operators/jenkins_job_trigger.py providers/jenkins/hooks/jenkins.py providers/jenkins/example_dags/example_jenkins_job_trigger.py providers/ftp/hooks/ftp.py providers/ftp/sensors/ftp.py providers/postgres/hooks/postgres.py providers/postgres/operators/postgres.py providers/postgres/example_dags/example_postgres.py providers/plexus/operators/job.py providers/plexus/hooks/plexus.py providers/plexus/example_dags/example_plexus.py providers/jira/sensors/jira.py providers/jira/hooks/jira.py providers/jira/operators/jira.py providers/tableau/hooks/tableau.py providers/tableau/operators/tableau_refresh_workbook.py providers/tableau/sensors/tableau_job_status.py providers/tableau/example_dags/example_tableau_refresh_workbook.py providers/airbyte/hooks/airbyte.py providers/airbyte/sensors/airbyte.py providers/airbyte/operators/airbyte.py providers/airbyte/example_dags/example_airbyte_trigger_job.py providers/grpc/hooks/grpc.py providers/grpc/operators/grpc.py providers/odbc/hooks/odbc.py providers/mongo/hooks/mongo.py providers/mongo/sensors/mongo.py providers/singularity/operators/singularity.py providers/singularity/example_dags/example_singularity.py providers/salesforce/hooks/salesforce.py providers/salesforce/hooks/tableau.py providers/exasol/hooks/exasol.py providers/exasol/operators/exasol.py providers/dingding/hooks/dingding.py providers/dingding/example_dags/example_dingding.py providers/dingding/operators/dingding.py providers/redis/sensors/redis_pub_sub.py providers/redis/sensors/redis_key.py providers/redis/hooks/redis.py providers/redis/operators/redis_publish.py providers/trino/hooks/trino.py providers/presto/hooks/presto.py providers/telegram/hooks/telegram.py providers/telegram/operators/telegram.py providers/telegram/example_dags/example_telegram.py providers/neo4j/hooks/neo4j.py providers/neo4j/operators/neo4j.py providers/neo4j/example_dags/example_neo4j.py providers/sendgrid/utils/emailer.py providers/discord/hooks/discord_webhook.py providers/discord/operators/discord_webhook.py providers/facebook/ads/hooks/ads.py providers/openfaas/hooks/openfaas.py providers/jdbc/hooks/jdbc.py providers/jdbc/operators/jdbc.py providers/jdbc/example_dags/example_jdbc_queries.py providers/datadog/hooks/datadog.py providers/datadog/sensors/datadog.py providers/opsgenie/operators/opsgenie_alert.py providers/opsgenie/hooks/opsgenie_alert.py providers/pagerduty/hooks/pagerduty.py providers/zendesk/hooks/zendesk.py providers/segment/hooks/segment.py providers/segment/operators/segment_track_event.py providers/papermill/operators/papermill.py providers/papermill/example_dags/example_papermill.py providers/sqlite/operators/sqlite.py providers/sqlite/hooks/sqlite.py providers/sqlite/example_dags/example_sqlite.py providers/vertica/hooks/vertica.py providers/vertica/operators/vertica.py providers/celery/sensors/celery_queue.py providers/cloudant/hooks/cloudant.py providers/samba/hooks/samba.py models/dag.py models/taskinstance.py models/baseoperator.py models/dagrun.py models/dagbag.py models/connection.py models/serialized_dag.py models/xcom.py models/variable.py models/dagcode.py models/pool.py models/renderedtifields.py models/sensorinstance.py models/skipmixin.py models/xcom_arg.py models/taskreschedule.py models/log.py models/crypto.py models/taskmixin.py models/taskfail.py models/dagpickle.py models/dagparam.py models/base.py models/slamiss.py models/errors.py www/views.py www/security.py www/api/experimental/endpoints.py www/extensions/init_views.py www/extensions/init_jinja_globals.py www/extensions/init_security.py www/extensions/init_manifest_files.py www/extensions/init_wsgi_middlewares.py www/extensions/init_appbuilder.py www/extensions/init_session.py www/extensions/init_appbuilder_links.py www/extensions/init_dagbag.py www/utils.py www/forms.py www/app.py www/decorators.py www/validators.py www/widgets.py www/auth.py www/gunicorn_config.py www/blueprints.py utils/dag_processing.py utils/log/file_task_handler.py utils/log/secrets_masker.py utils/log/logging_mixin.py utils/log/file_processor_handler.py utils/log/colored_log.py utils/log/log_reader.py utils/log/json_formatter.py utils/log/cloudwatch_task_handler.py utils/log/gcs_task_handler.py utils/log/stackdriver_task_handler.py utils/log/wasb_task_handler.py utils/log/es_task_handler.py utils/log/s3_task_handler.py utils/db.py utils/task_group.py utils/cli.py utils/process_utils.py utils/email.py utils/dates.py utils/file.py utils/helpers.py utils/sqlalchemy.py utils/python_virtualenv.py utils/dot_renderer.py utils/timezone.py utils/operator_helpers.py utils/operator_resources.py utils/edgemodifier.py utils/code_utils.py utils/retries.py utils/state.py utils/orm_event_handlers.py utils/platform.py utils/cli_action_loggers.py utils/dag_cycle_tester.py utils/session.py utils/callback_requests.py utils/yaml.py utils/json.py utils/timeout.py utils/trigger_rule.py utils/types.py utils/compression.py utils/weight_rule.py utils/configuration.py utils/serve_logs.py utils/module_loading.py utils/mixins.py utils/entry_points.py utils/decorators.py utils/docs.py utils/event_scheduler.py utils/strings.py utils/net.py _vendor/connexion/decorators/validation.py _vendor/connexion/decorators/security.py _vendor/connexion/decorators/uri_parsing.py _vendor/connexion/decorators/response.py _vendor/connexion/decorators/parameter.py _vendor/connexion/decorators/metrics.py _vendor/connexion/decorators/coroutine_wrappers.py _vendor/connexion/decorators/decorator.py _vendor/connexion/decorators/produces.py _vendor/connexion/operations/openapi.py _vendor/connexion/operations/abstract.py _vendor/connexion/operations/swagger2.py _vendor/connexion/operations/secure.py _vendor/connexion/operations/__init__.py _vendor/connexion/operations/compat.py _vendor/connexion/apis/abstract.py _vendor/connexion/apis/aiohttp_api.py _vendor/connexion/apis/flask_api.py _vendor/connexion/apis/flask_utils.py _vendor/connexion/apis/__init__.py _vendor/connexion/apps/abstract.py _vendor/connexion/apps/aiohttp_app.py _vendor/connexion/apps/flask_app.py _vendor/connexion/apps/__init__.py _vendor/connexion/spec.py _vendor/connexion/utils.py _vendor/connexion/cli.py _vendor/connexion/resolver.py _vendor/connexion/exceptions.py _vendor/connexion/json_schema.py _vendor/connexion/options.py _vendor/connexion/setup.py _vendor/connexion/handlers.py _vendor/connexion/jsonifier.py _vendor/connexion/mock.py _vendor/connexion/lifecycle.py _vendor/connexion/__init__.py _vendor/connexion/problem.py _vendor/connexion/http_facts.py cli/commands/webserver_command.py cli/commands/info_command.py cli/commands/task_command.py cli/commands/dag_command.py cli/commands/user_command.py cli/commands/standalone_command.py cli/commands/connection_command.py cli/commands/celery_command.py cli/commands/pool_command.py cli/commands/kubernetes_command.py cli/commands/variable_command.py cli/commands/db_command.py cli/commands/scheduler_command.py cli/commands/provider_command.py cli/commands/plugins_command.py cli/commands/jobs_command.py cli/commands/cheat_sheet_command.py cli/commands/config_command.py cli/commands/kerberos_command.py cli/commands/role_command.py cli/commands/sync_perm_command.py cli/commands/rotate_fernet_key_command.py cli/commands/legacy_commands.py cli/commands/version_command.py cli/cli_parser.py cli/simple_table.py api_connexion/endpoints/task_instance_endpoint.py api_connexion/endpoints/connection_endpoint.py api_connexion/endpoints/role_and_permission_endpoint.py api_connexion/endpoints/dag_run_endpoint.py api_connexion/endpoints/pool_endpoint.py api_connexion/endpoints/variable_endpoint.py api_connexion/endpoints/dag_endpoint.py api_connexion/endpoints/log_endpoint.py api_connexion/endpoints/xcom_endpoint.py api_connexion/endpoints/config_endpoint.py api_connexion/endpoints/task_endpoint.py api_connexion/endpoints/user_endpoint.py api_connexion/endpoints/extra_link_endpoint.py api_connexion/endpoints/import_error_endpoint.py api_connexion/endpoints/event_log_endpoint.py api_connexion/endpoints/dag_source_endpoint.py api_connexion/endpoints/health_endpoint.py api_connexion/endpoints/provider_endpoint.py api_connexion/endpoints/plugin_endpoint.py api_connexion/endpoints/version_endpoint.py api_connexion/schemas/task_instance_schema.py api_connexion/schemas/common_schema.py api_connexion/schemas/dag_schema.py api_connexion/schemas/dag_run_schema.py api_connexion/schemas/task_schema.py api_connexion/schemas/role_and_permission_schema.py api_connexion/schemas/pool_schema.py api_connexion/schemas/user_schema.py api_connexion/schemas/connection_schema.py api_connexion/schemas/event_log_schema.py api_connexion/schemas/xcom_schema.py api_connexion/schemas/plugin_schema.py api_connexion/schemas/error_schema.py api_connexion/schemas/config_schema.py api_connexion/schemas/provider_schema.py api_connexion/schemas/sla_miss_schema.py api_connexion/schemas/health_schema.py api_connexion/schemas/enum_schemas.py api_connexion/schemas/log_schema.py api_connexion/schemas/variable_schema.py api_connexion/schemas/version_schema.py api_connexion/schemas/dag_source_schema.py api_connexion/parameters.py api_connexion/exceptions.py api_connexion/security.py contrib/operators/dataproc_operator.py contrib/operators/gcp_vision_operator.py contrib/operators/gcp_sql_operator.py contrib/operators/gcp_transfer_operator.py contrib/operators/gcp_bigtable_operator.py contrib/operators/gcp_compute_operator.py contrib/operators/gcp_spanner_operator.py contrib/operators/pubsub_operator.py contrib/operators/gcp_dlp_operator.py contrib/operators/mlengine_operator.py contrib/operators/gcp_natural_language_operator.py contrib/operators/gcp_container_operator.py contrib/operators/dataflow_operator.py contrib/operators/awsbatch_operator.py contrib/operators/gcs_acl_operator.py contrib/operators/gcp_function_operator.py contrib/operators/ecs_operator.py contrib/operators/gcs_list_operator.py contrib/operators/bigquery_operator.py contrib/operators/gcs_download_operator.py contrib/operators/gcp_translate_speech_operator.py contrib/operators/bigquery_to_gcs.py contrib/operators/oracle_to_oracle_transfer.py contrib/operators/vertica_to_hive.py contrib/operators/gcs_to_s3.py contrib/operators/file_to_gcs.py contrib/operators/datastore_import_operator.py contrib/operators/gcs_to_gcs.py contrib/operators/gcp_text_to_speech_operator.py contrib/operators/cassandra_to_gcs.py contrib/operators/gcs_to_bq.py contrib/operators/gcs_delete_operator.py contrib/operators/gcs_operator.py contrib/operators/adls_to_gcs.py contrib/operators/postgres_to_gcs_operator.py contrib/operators/mysql_to_gcs.py contrib/operators/gcp_speech_to_text_operator.py contrib/operators/bigquery_table_delete_operator.py contrib/operators/mssql_to_gcs.py contrib/operators/datastore_export_operator.py contrib/operators/sql_to_gcs.py contrib/operators/vertica_to_mysql.py contrib/operators/sagemaker_tuning_operator.py contrib/operators/adls_list_operator.py contrib/operators/sagemaker_endpoint_config_operator.py contrib/operators/sagemaker_base_operator.py contrib/operators/mongo_to_s3.py contrib/operators/sagemaker_endpoint_operator.py contrib/operators/spark_submit_operator.py contrib/operators/aws_athena_operator.py contrib/operators/dingding_operator.py contrib/operators/sns_publish_operator.py contrib/operators/gcs_to_gdrive_operator.py contrib/operators/dynamodb_to_s3.py contrib/operators/grpc_operator.py contrib/operators/winrm_operator.py contrib/operators/bigquery_to_mysql_operator.py contrib/operators/sagemaker_training_operator.py contrib/operators/s3_list_operator.py contrib/operators/jenkins_job_trigger_operator.py contrib/operators/azure_container_instances_operator.py contrib/operators/bigquery_get_data.py contrib/operators/spark_sql_operator.py contrib/operators/s3_delete_objects_operator.py contrib/operators/file_to_wasb.py contrib/operators/segment_track_event_operator.py contrib/operators/qubole_check_operator.py contrib/operators/druid_operator.py contrib/operators/gcp_cloud_build_operator.py contrib/operators/oracle_to_azure_data_lake_transfer.py contrib/operators/azure_cosmos_operator.py contrib/operators/vertica_operator.py contrib/operators/jira_operator.py contrib/operators/s3_to_gcs_transfer_operator.py contrib/operators/gcp_tasks_operator.py contrib/operators/kubernetes_pod_operator.py contrib/operators/sqoop_operator.py contrib/operators/sagemaker_model_operator.py contrib/operators/s3_copy_object_operator.py contrib/operators/imap_attachment_to_s3_operator.py contrib/operators/wasb_delete_blob_operator.py contrib/operators/ssh_operator.py contrib/operators/bigquery_check_operator.py contrib/operators/s3_to_gcs_operator.py contrib/operators/snowflake_operator.py contrib/operators/bigquery_to_bigquery.py contrib/operators/emr_create_job_flow_operator.py contrib/operators/gcp_video_intelligence_operator.py contrib/operators/slack_webhook_operator.py contrib/operators/s3_to_sftp_operator.py contrib/operators/hive_to_dynamodb.py contrib/operators/gcp_translate_operator.py contrib/operators/discord_webhook_operator.py contrib/operators/docker_swarm_operator.py contrib/operators/aws_sqs_publish_operator.py contrib/operators/opsgenie_alert_operator.py contrib/operators/qubole_operator.py contrib/operators/spark_jdbc_operator.py contrib/operators/databricks_operator.py contrib/operators/emr_terminate_job_flow_operator.py contrib/operators/sagemaker_transform_operator.py contrib/operators/redis_publish_operator.py contrib/operators/emr_add_steps_operator.py contrib/operators/sftp_to_s3_operator.py contrib/operators/sftp_operator.py contrib/operators/gcs_to_gcs_transfer_operator.py contrib/operators/__init__.py contrib/hooks/gcp_sql_hook.py contrib/hooks/gcp_function_hook.py contrib/hooks/gcp_transfer_hook.py contrib/hooks/aws_hook.py contrib/hooks/gcp_spanner_hook.py contrib/hooks/gcs_hook.py contrib/hooks/gcp_compute_hook.py contrib/hooks/gcp_api_base_hook.py contrib/hooks/gcp_kms_hook.py contrib/hooks/gcp_dataproc_hook.py contrib/hooks/gcp_container_hook.py contrib/hooks/gcp_text_to_speech_hook.py contrib/hooks/gcp_speech_to_text_hook.py contrib/hooks/gcp_dataflow_hook.py contrib/hooks/openfaas_hook.py contrib/hooks/gcp_video_intelligence_hook.py contrib/hooks/aws_athena_hook.py contrib/hooks/salesforce_hook.py contrib/hooks/gdrive_hook.py contrib/hooks/snowflake_hook.py contrib/hooks/pagerduty_hook.py contrib/hooks/aws_sqs_hook.py contrib/hooks/fs_hook.py contrib/hooks/wasb_hook.py contrib/hooks/cloudant_hook.py contrib/hooks/gcp_translate_hook.py contrib/hooks/aws_datasync_hook.py contrib/hooks/imap_hook.py contrib/hooks/gcp_tasks_hook.py contrib/hooks/azure_fileshare_hook.py contrib/hooks/azure_container_instance_hook.py contrib/hooks/segment_hook.py contrib/hooks/azure_container_volume_hook.py contrib/hooks/spark_submit_hook.py contrib/hooks/datadog_hook.py contrib/hooks/discord_webhook_hook.py contrib/hooks/gcp_dlp_hook.py contrib/hooks/aws_lambda_hook.py contrib/hooks/ftp_hook.py contrib/hooks/pinot_hook.py contrib/hooks/spark_sql_hook.py contrib/hooks/winrm_hook.py contrib/hooks/aws_sns_hook.py contrib/hooks/aws_dynamodb_hook.py contrib/hooks/aws_firehose_hook.py contrib/hooks/slack_webhook_hook.py contrib/hooks/jenkins_hook.py contrib/hooks/gcp_bigtable_hook.py contrib/hooks/datastore_hook.py contrib/hooks/opsgenie_alert_hook.py contrib/hooks/jira_hook.py contrib/hooks/gcp_mlengine_hook.py contrib/hooks/sftp_hook.py contrib/hooks/redis_hook.py contrib/hooks/qubole_check_hook.py contrib/hooks/qubole_hook.py contrib/hooks/grpc_hook.py contrib/hooks/redshift_hook.py contrib/hooks/gcp_pubsub_hook.py contrib/hooks/sqoop_hook.py contrib/hooks/databricks_hook.py contrib/hooks/vertica_hook.py contrib/hooks/azure_data_lake_hook.py contrib/hooks/ssh_hook.py contrib/hooks/spark_jdbc_hook.py contrib/hooks/aws_logs_hook.py contrib/hooks/aws_glue_catalog_hook.py contrib/hooks/sagemaker_hook.py contrib/hooks/dingding_hook.py contrib/hooks/cassandra_hook.py contrib/hooks/gcp_natural_language_hook.py contrib/hooks/gcp_vision_hook.py contrib/hooks/azure_cosmos_hook.py contrib/hooks/mongo_hook.py contrib/hooks/gcp_cloud_build_hook.py contrib/hooks/bigquery_hook.py contrib/hooks/emr_hook.py contrib/hooks/azure_container_registry_hook.py contrib/hooks/__init__.py contrib/sensors/gcs_sensor.py contrib/sensors/hdfs_sensor.py contrib/sensors/gcp_transfer_sensor.py contrib/sensors/bigquery_sensor.py contrib/sensors/emr_job_flow_sensor.py contrib/sensors/mongo_sensor.py contrib/sensors/datadog_sensor.py contrib/sensors/aws_redshift_cluster_sensor.py contrib/sensors/sagemaker_transform_sensor.py contrib/sensors/sagemaker_tuning_sensor.py contrib/sensors/pubsub_sensor.py contrib/sensors/jira_sensor.py contrib/sensors/ftp_sensor.py contrib/sensors/cassandra_table_sensor.py contrib/sensors/sagemaker_endpoint_sensor.py contrib/sensors/azure_cosmos_sensor.py contrib/sensors/emr_step_sensor.py contrib/sensors/celery_queue_sensor.py contrib/sensors/sagemaker_base_sensor.py contrib/sensors/redis_pub_sub_sensor.py contrib/sensors/redis_key_sensor.py contrib/sensors/wasb_sensor.py contrib/sensors/emr_base_sensor.py contrib/sensors/file_sensor.py contrib/sensors/cassandra_record_sensor.py contrib/sensors/imap_attachment_sensor.py contrib/sensors/aws_athena_sensor.py contrib/sensors/bash_sensor.py contrib/sensors/sftp_sensor.py contrib/sensors/sagemaker_training_sensor.py contrib/sensors/aws_glue_catalog_partition_sensor.py contrib/sensors/weekday_sensor.py contrib/sensors/qubole_sensor.py contrib/sensors/python_sensor.py contrib/sensors/aws_sqs_sensor.py contrib/sensors/__init__.py contrib/utils/log/task_handler_with_custom_formatter.py contrib/utils/log/__init__.py contrib/utils/sendgrid.py contrib/utils/gcp_field_sanitizer.py contrib/utils/weekday.py contrib/utils/mlengine_prediction_summary.py contrib/utils/mlengine_operator_utils.py contrib/utils/gcp_field_validator.py contrib/utils/__init__.py contrib/secrets/gcp_secrets_manager.py contrib/secrets/hashicorp_vault.py contrib/secrets/aws_systems_manager.py contrib/secrets/azure_key_vault.py contrib/secrets/aws_secrets_manager.py contrib/secrets/__init__.py contrib/task_runner/cgroup_task_runner.py contrib/task_runner/__init__.py contrib/__init__.py jobs/scheduler_job.py jobs/backfill_job.py jobs/base_job.py jobs/local_task_job.py executors/kubernetes_executor.py executors/celery_executor.py executors/local_executor.py executors/base_executor.py executors/celery_kubernetes_executor.py executors/debug_executor.py executors/dask_executor.py executors/executor_loader.py executors/sequential_executor.py executors/executor_constants.py operators/sql.py operators/python.py operators/subdag.py operators/trigger_dagrun.py operators/bash.py operators/datetime.py operators/weekday.py operators/generic_transfer.py operators/email.py operators/check_operator.py operators/latest_only.py operators/presto_check_operator.py operators/branch.py operators/sql_branch_operator.py operators/hive_to_druid.py operators/presto_to_mysql.py operators/mysql_to_hive.py operators/mssql_to_hive.py operators/s3_to_redshift_operator.py operators/redshift_to_s3_operator.py operators/hive_to_mysql.py operators/dummy.py operators/s3_to_hive_operator.py operators/google_api_to_s3_transfer.py operators/pig_operator.py operators/hive_stats_operator.py operators/email_operator.py operators/postgres_operator.py operators/dummy_operator.py operators/s3_file_transform_operator.py operators/dagrun_operator.py operators/docker_operator.py operators/slack_operator.py operators/papermill_operator.py operators/branch_operator.py operators/bash_operator.py operators/mssql_operator.py operators/mysql_operator.py operators/http_operator.py operators/hive_operator.py operators/subdag_operator.py operators/latest_only_operator.py operators/oracle_operator.py operators/python_operator.py operators/druid_check_operator.py operators/hive_to_samba_operator.py operators/jdbc_operator.py operators/sqlite_operator.py sensors/smart_sensor.py sensors/base.py sensors/external_task.py sensors/sql.py sensors/bash.py sensors/filesystem.py sensors/weekday.py sensors/python.py sensors/date_time.py sensors/time_delta.py sensors/time_sensor.py sensors/time_delta_sensor.py sensors/date_time_sensor.py sensors/hive_partition_sensor.py sensors/base_sensor_operator.py sensors/metastore_partition_sensor.py sensors/s3_prefix_sensor.py sensors/s3_key_sensor.py sensors/http_sensor.py sensors/web_hdfs_sensor.py sensors/external_task_sensor.py sensors/sql_sensor.py sensors/named_hive_partition_sensor.py kubernetes/pod_generator.py kubernetes/pod_launcher_deprecated.py kubernetes/pod_generator_deprecated.py kubernetes/kube_client.py kubernetes/refresh_config.py kubernetes/secret.py kubernetes/kube_config.py kubernetes/kubernetes_helper_functions.py kubernetes/k8s_model.py kubernetes/pod.py kubernetes/pod_runtime_info_env.py kubernetes/volume_mount.py kubernetes/volume.py kubernetes/pod_launcher.py example_dags/example_complex.py example_dags/example_kubernetes_executor_config.py example_dags/tutorial_etl_dag.py example_dags/example_python_operator.py example_dags/example_xcom.py example_dags/example_dag_decorator.py example_dags/example_passing_params_via_test_command.py example_dags/example_task_group.py example_dags/example_task_group_decorator.py example_dags/example_xcomargs.py example_dags/tutorial_taskflow_api_etl_virtualenv.py example_dags/tutorial_taskflow_api_etl.py example_dags/example_skip_dag.py example_dags/example_bash_operator.py example_dags/example_kubernetes_executor.py example_dags/example_branch_operator.py example_dags/example_nested_branch_dag.py example_dags/example_branch_datetime_operator.py example_dags/example_branch_python_dop_operator_3.py example_dags/tutorial.py example_dags/example_branch_labels.py example_dags/example_latest_only_with_trigger.py example_dags/example_subdag_operator.py example_dags/example_short_circuit_operator.py example_dags/example_external_task_marker_dag.py example_dags/example_branch_day_of_week_operator.py example_dags/example_latest_only.py example_dags/example_trigger_target_dag.py example_dags/subdags/subdag.py example_dags/example_trigger_controller_dag.py example_dags/test_utils.py example_dags/libs/helper.py api/common/experimental/mark_tasks.py api/common/experimental/pool.py api/common/experimental/trigger_dag.py api/common/experimental/delete_dag.py api/common/experimental/get_lineage.py api/common/experimental/get_task_instance.py api/common/experimental/get_dag_runs.py api/common/experimental/get_code.py api/common/experimental/get_dag_run_state.py api/common/experimental/get_task.py api/auth/backend/kerberos_auth.py api/auth/backend/basic_auth.py api/auth/backend/deny_all.py api/auth/backend/default.py api/client/json_client.py api/client/local_client.py api/client/api_client.py serialization/serialized_objects.py serialization/json_schema.py serialization/enums.py serialization/helpers.py ti_deps/deps/trigger_rule_dep.py ti_deps/deps/base_ti_dep.py ti_deps/deps/prev_dagrun_dep.py ti_deps/deps/not_previously_skipped_dep.py ti_deps/deps/ready_to_reschedule.py ti_deps/deps/valid_state_dep.py ti_deps/deps/pool_slots_available_dep.py ti_deps/deps/not_in_retry_period_dep.py ti_deps/deps/dagrun_exists_dep.py ti_deps/deps/task_not_running_dep.py ti_deps/deps/task_concurrency_dep.py ti_deps/deps/runnable_exec_date_dep.py ti_deps/deps/dagrun_id_dep.py ti_deps/deps/exec_date_after_start_date_dep.py ti_deps/deps/dag_ti_slots_available_dep.py ti_deps/deps/dag_unpaused_dep.py ti_deps/dep_context.py ti_deps/dependencies_deps.py ti_deps/dependencies_states.py hooks/dbapi.py hooks/base.py hooks/subprocess.py hooks/filesystem.py hooks/pig_hook.py hooks/hdfs_hook.py hooks/hive_hooks.py hooks/oracle_hook.py hooks/presto_hook.py hooks/dbapi_hook.py hooks/postgres_hook.py hooks/samba_hook.py hooks/druid_hook.py hooks/webhdfs_hook.py hooks/base_hook.py hooks/sqlite_hook.py hooks/slack_hook.py hooks/zendesk_hook.py hooks/mysql_hook.py hooks/docker_hook.py hooks/mssql_hook.py hooks/jdbc_hook.py hooks/S3_hook.py hooks/http_hook.py task/task_runner/cgroup_task_runner.py task/task_runner/standard_task_runner.py task/task_runner/base_task_runner.py secrets/local_filesystem.py secrets/base_secrets.py secrets/metastore.py secrets/environment_variables.py plugins_manager.py providers_manager.py stats.py settings.py decorators/base.py decorators/python_virtualenv.py decorators/task_group.py decorators/python.py security/kerberos.py security/permissions.py security/utils.py config_templates/airflow_local_settings.py config_templates/default_celery.py config_templates/default_webserver_config.py sentry.py logging_config.py lineage/entities.py lineage/backend.py macros/hive.py mypy/plugin/decorators.py smart_sensor_dags/smart_sensor_group.py version.py typing_compat.py compat/functools.py templates.py

No flags found

Use flags to group coverage reports by test type, project and/or folders.
Then setup custom commit statuses and notifications for each flag.

e.g., #unittest #integration

#production #enterprise

#frontend #backend

Learn more about Codecov Flags here.

Showing 7 of 41 files from the diff.
Other files ignored by Codecov
chart/Chart.yaml has changed.
chart/values.yaml has changed.
.gitignore has changed.
setup.py has changed.

@@ -48,6 +48,11 @@
Loading
48 48
    :type at_all: bool
49 49
    """
50 50
51 +
    conn_name_attr = 'dingding_conn_id'
52 +
    default_conn_name = 'dingding_default'
53 +
    conn_type = 'dingding'
54 +
    hook_name = 'Dingding'
55 +
51 56
    def __init__(
52 57
        self,
53 58
        dingding_conn_id='dingding_default',

@@ -28,7 +28,7 @@
Loading
28 28
from airflow.exceptions import AirflowNotFoundException
29 29
from airflow.hooks.base import BaseHook
30 30
from airflow.models import Connection
31 -
from airflow.secrets.local_filesystem import _parse_secret_file
31 +
from airflow.secrets.local_filesystem import load_connections_dict
32 32
from airflow.utils import cli as cli_utils, yaml
33 33
from airflow.utils.cli import suppress_logs_and_warning
34 34
from airflow.utils.session import create_session
@@ -247,15 +247,13 @@
Loading
247 247
248 248
def _import_helper(file_path):
249 249
    """Load connections from a file and save them to the DB. On collision, skip."""
250 -
    connections_dict = _parse_secret_file(file_path)
250 +
    connections_dict = load_connections_dict(file_path)
251 251
    with create_session() as session:
252 -
        for conn_id, conn_dict in connections_dict.items():
252 +
        for conn_id, conn in connections_dict.items():
253 253
            if session.query(Connection).filter(Connection.conn_id == conn_id).first():
254 254
                print(f'Could not import connection {conn_id}: connection already exists.')
255 255
                continue
256 256
257 -
            # Add the connection to the DB
258 -
            connection = Connection(conn_id, **dict(conn_dict.items()))
259 -
            session.add(connection)
257 +
            session.add(conn)
260 258
            session.commit()
261 259
            print(f'Imported connection {conn_id}')

@@ -41,6 +41,11 @@
Loading
41 41
42 42
    """
43 43
44 +
    conn_name_attr = 'opsgenie_conn_id'
45 +
    default_conn_name = 'opsgenie_default'
46 +
    conn_type = 'opsgenie'
47 +
    hook_name = 'Opsgenie'
48 +
44 49
    def __init__(self, opsgenie_conn_id: str = 'opsgenie_default', *args, **kwargs) -> None:
45 50
        super().__init__(http_conn_id=opsgenie_conn_id, *args, **kwargs)  # type: ignore[misc]
46 51

@@ -61,6 +61,11 @@
Loading
61 61
    :type proxy: str
62 62
    """
63 63
64 +
    conn_name_attr = 'http_conn_id'
65 +
    default_conn_name = 'slack_default'
66 +
    conn_type = 'slackwebhook'
67 +
    hook_name = 'Slack Webhook'
68 +
64 69
    # pylint: disable=too-many-arguments
65 70
    def __init__(
66 71
        self,

@@ -33,6 +33,11 @@
Loading
33 33
    :type api_version: str
34 34
    """
35 35
36 +
    conn_name_attr = 'airbyte_conn_id'
37 +
    default_conn_name = 'airbyte_default'
38 +
    conn_type = 'airbyte'
39 +
    hook_name = 'Airbyte'
40 +
36 41
    RUNNING = "running"
37 42
    SUCCEEDED = "succeeded"
38 43
    CANCELLED = "cancelled"

Click to load this diff.
Loading diff...

Click to load this diff.
Loading diff...

Learn more Showing 10 files with coverage changes found.

Changes in airflow/providers/dingding/hooks/dingding.py
+3
Loading file...
Changes in airflow/providers/discord/hooks/discord_webhook.py
+2
Loading file...
Changes in airflow/providers/slack/hooks/slack_webhook.py
+2
+1
Loading file...
Changes in airflow/executors/base_executor.py
-1
+1
Loading file...
Changes in airflow/utils/dag_processing.py
-4
+4
Loading file...
Changes in airflow/providers/airbyte/hooks/airbyte.py
-3
Loading file...
Changes in airflow/jobs/backfill_job.py
-1
+1
Loading file...
Changes in airflow/providers/opsgenie/hooks/opsgenie_alert.py
-1
Loading file...
Changes in airflow/cli/commands/webserver_command.py
-1
+1
Loading file...
Changes in airflow/task/task_runner/base_task_runner.py
-1
+1
Loading file...
Files Coverage
example_dags/example_airbyte_trigger_job.py 100.00%
hooks/airbyte.py 92.50%
operators/airbyte.py 100.00%
sensors/airbyte.py 96.42%
Folder Totals (4 files) 96.11%
Project Totals (1243 files) 88.44%
Loading