All modules for which code is available
- airflow.contrib.example_dags.example_gcp_bigtable_operators
- airflow.contrib.example_dags.example_gcp_compute
- airflow.contrib.example_dags.example_gcp_compute_igm
- airflow.contrib.example_dags.example_gcp_function
- airflow.contrib.example_dags.example_gcp_natural_language
- airflow.contrib.example_dags.example_gcp_spanner
- airflow.contrib.example_dags.example_gcp_sql
- airflow.contrib.example_dags.example_gcp_sql_query
- airflow.contrib.example_dags.example_gcp_transfer
- airflow.contrib.example_dags.example_gcp_translate
- airflow.contrib.example_dags.example_gcp_vision
- airflow.contrib.example_dags.example_gcs_acl
- airflow.contrib.example_dags.example_gcs_to_bq_operator
- airflow.contrib.executors.kubernetes_executor
- airflow.contrib.executors.mesos_executor
- airflow.contrib.hooks
- airflow.contrib.hooks.aws_athena_hook
- airflow.contrib.hooks.aws_dynamodb_hook
- airflow.contrib.hooks.aws_firehose_hook
- airflow.contrib.hooks.aws_glue_catalog_hook
- airflow.contrib.hooks.aws_hook
- airflow.contrib.hooks.aws_lambda_hook
- airflow.contrib.hooks.aws_sns_hook
- airflow.contrib.hooks.azure_container_instance_hook
- airflow.contrib.hooks.azure_container_registry_hook
- airflow.contrib.hooks.azure_container_volume_hook
- airflow.contrib.hooks.azure_cosmos_hook
- airflow.contrib.hooks.azure_data_lake_hook
- airflow.contrib.hooks.azure_fileshare_hook
- airflow.contrib.hooks.bigquery_hook
- airflow.contrib.hooks.cassandra_hook
- airflow.contrib.hooks.cloudant_hook
- airflow.contrib.hooks.databricks_hook
- airflow.contrib.hooks.datadog_hook
- airflow.contrib.hooks.datastore_hook
- airflow.contrib.hooks.dingding_hook
- airflow.contrib.hooks.discord_webhook_hook
- airflow.contrib.hooks.emr_hook
- airflow.contrib.hooks.fs_hook
- airflow.contrib.hooks.ftp_hook
- airflow.contrib.hooks.gcp_api_base_hook
- airflow.contrib.hooks.gcp_bigtable_hook
- airflow.contrib.hooks.gcp_compute_hook
- airflow.contrib.hooks.gcp_container_hook
- airflow.contrib.hooks.gcp_dataflow_hook
- airflow.contrib.hooks.gcp_dataproc_hook
- airflow.contrib.hooks.gcp_function_hook
- airflow.contrib.hooks.gcp_kms_hook
- airflow.contrib.hooks.gcp_mlengine_hook
- airflow.contrib.hooks.gcp_natural_language_hook
- airflow.contrib.hooks.gcp_pubsub_hook
- airflow.contrib.hooks.gcp_spanner_hook
- airflow.contrib.hooks.gcp_sql_hook
- airflow.contrib.hooks.gcp_transfer_hook
- airflow.contrib.hooks.gcp_translate_hook
- airflow.contrib.hooks.gcp_vision_hook
- airflow.contrib.hooks.gcs_hook
- airflow.contrib.hooks.imap_hook
- airflow.contrib.hooks.jenkins_hook
- airflow.contrib.hooks.jira_hook
- airflow.contrib.hooks.mongo_hook
- airflow.contrib.hooks.openfaas_hook
- airflow.contrib.hooks.opsgenie_alert_hook
- airflow.contrib.hooks.pinot_hook
- airflow.contrib.hooks.qubole_check_hook
- airflow.contrib.hooks.qubole_hook
- airflow.contrib.hooks.redis_hook
- airflow.contrib.hooks.redshift_hook
- airflow.contrib.hooks.sagemaker_hook
- airflow.contrib.hooks.salesforce_hook
- airflow.contrib.hooks.segment_hook
- airflow.contrib.hooks.sftp_hook
- airflow.contrib.hooks.slack_webhook_hook
- airflow.contrib.hooks.snowflake_hook
- airflow.contrib.hooks.spark_jdbc_hook
- airflow.contrib.hooks.spark_jdbc_script
- airflow.contrib.hooks.spark_sql_hook
- airflow.contrib.hooks.spark_submit_hook
- airflow.contrib.hooks.sqoop_hook
- airflow.contrib.hooks.ssh_hook
- airflow.contrib.hooks.vertica_hook
- airflow.contrib.hooks.wasb_hook
- airflow.contrib.hooks.winrm_hook
- airflow.contrib.operators
- airflow.contrib.operators.adls_list_operator
- airflow.contrib.operators.adls_to_gcs
- airflow.contrib.operators.aws_athena_operator
- airflow.contrib.operators.awsbatch_operator
- airflow.contrib.operators.azure_container_instances_operator
- airflow.contrib.operators.azure_cosmos_operator
- airflow.contrib.operators.bigquery_check_operator
- airflow.contrib.operators.bigquery_get_data
- airflow.contrib.operators.bigquery_operator
- airflow.contrib.operators.bigquery_table_delete_operator
- airflow.contrib.operators.bigquery_to_bigquery
- airflow.contrib.operators.bigquery_to_gcs
- airflow.contrib.operators.cassandra_to_gcs
- airflow.contrib.operators.databricks_operator
- airflow.contrib.operators.dataflow_operator
- airflow.contrib.operators.dataproc_operator
- airflow.contrib.operators.datastore_export_operator
- airflow.contrib.operators.datastore_import_operator
- airflow.contrib.operators.dingding_operator
- airflow.contrib.operators.discord_webhook_operator
- airflow.contrib.operators.druid_operator
- airflow.contrib.operators.ecs_operator
- airflow.contrib.operators.emr_add_steps_operator
- airflow.contrib.operators.emr_create_job_flow_operator
- airflow.contrib.operators.emr_terminate_job_flow_operator
- airflow.contrib.operators.file_to_gcs
- airflow.contrib.operators.file_to_wasb
- airflow.contrib.operators.gcp_bigtable_operator
- airflow.contrib.operators.gcp_compute_operator
- airflow.contrib.operators.gcp_container_operator
- airflow.contrib.operators.gcp_function_operator
- airflow.contrib.operators.gcp_natural_language_operator
- airflow.contrib.operators.gcp_spanner_operator
- airflow.contrib.operators.gcp_sql_operator
- airflow.contrib.operators.gcp_transfer_operator
- airflow.contrib.operators.gcp_translate_operator
- airflow.contrib.operators.gcp_vision_operator
- airflow.contrib.operators.gcs_acl_operator
- airflow.contrib.operators.gcs_download_operator
- airflow.contrib.operators.gcs_list_operator
- airflow.contrib.operators.gcs_operator
- airflow.contrib.operators.gcs_to_bq
- airflow.contrib.operators.gcs_to_gcs
- airflow.contrib.operators.gcs_to_s3
- airflow.contrib.operators.hipchat_operator
- airflow.contrib.operators.hive_to_dynamodb
- airflow.contrib.operators.imap_attachment_to_s3_operator
- airflow.contrib.operators.jenkins_job_trigger_operator
- airflow.contrib.operators.jira_operator
- airflow.contrib.operators.kubernetes_pod_operator
- airflow.contrib.operators.mlengine_operator
- airflow.contrib.operators.mongo_to_s3
- airflow.contrib.operators.mysql_to_gcs
- airflow.contrib.operators.opsgenie_alert_operator
- airflow.contrib.operators.oracle_to_azure_data_lake_transfer
- airflow.contrib.operators.oracle_to_oracle_transfer
- airflow.contrib.operators.postgres_to_gcs_operator
- airflow.contrib.operators.pubsub_operator
- airflow.contrib.operators.qubole_check_operator
- airflow.contrib.operators.qubole_operator
- airflow.contrib.operators.s3_copy_object_operator
- airflow.contrib.operators.s3_delete_objects_operator
- airflow.contrib.operators.s3_list_operator
- airflow.contrib.operators.s3_to_gcs_operator
- airflow.contrib.operators.s3_to_sftp_operator
- airflow.contrib.operators.sagemaker_base_operator
- airflow.contrib.operators.sagemaker_endpoint_config_operator
- airflow.contrib.operators.sagemaker_endpoint_operator
- airflow.contrib.operators.sagemaker_model_operator
- airflow.contrib.operators.sagemaker_training_operator
- airflow.contrib.operators.sagemaker_transform_operator
- airflow.contrib.operators.sagemaker_tuning_operator
- airflow.contrib.operators.segment_track_event_operator
- airflow.contrib.operators.sftp_operator
- airflow.contrib.operators.sftp_to_s3_operator
- airflow.contrib.operators.slack_webhook_operator
- airflow.contrib.operators.snowflake_operator
- airflow.contrib.operators.sns_publish_operator
- airflow.contrib.operators.spark_jdbc_operator
- airflow.contrib.operators.spark_sql_operator
- airflow.contrib.operators.spark_submit_operator
- airflow.contrib.operators.sqoop_operator
- airflow.contrib.operators.ssh_operator
- airflow.contrib.operators.vertica_operator
- airflow.contrib.operators.vertica_to_hive
- airflow.contrib.operators.vertica_to_mysql
- airflow.contrib.operators.wasb_delete_blob_operator
- airflow.contrib.operators.winrm_operator
- airflow.contrib.sensors.aws_athena_sensor
- airflow.contrib.sensors.aws_glue_catalog_partition_sensor
- airflow.contrib.sensors.aws_redshift_cluster_sensor
- airflow.contrib.sensors.azure_cosmos_sensor
- airflow.contrib.sensors.bash_sensor
- airflow.contrib.sensors.bigquery_sensor
- airflow.contrib.sensors.cassandra_record_sensor
- airflow.contrib.sensors.cassandra_table_sensor
- airflow.contrib.sensors.datadog_sensor
- airflow.contrib.sensors.emr_base_sensor
- airflow.contrib.sensors.emr_job_flow_sensor
- airflow.contrib.sensors.emr_step_sensor
- airflow.contrib.sensors.file_sensor
- airflow.contrib.sensors.ftp_sensor
- airflow.contrib.sensors.gcp_transfer_sensor
- airflow.contrib.sensors.gcs_sensor
- airflow.contrib.sensors.hdfs_sensor
- airflow.contrib.sensors.imap_attachment_sensor
- airflow.contrib.sensors.jira_sensor
- airflow.contrib.sensors.mongo_sensor
- airflow.contrib.sensors.pubsub_sensor
- airflow.contrib.sensors.python_sensor
- airflow.contrib.sensors.qubole_sensor
- airflow.contrib.sensors.redis_key_sensor
- airflow.contrib.sensors.redis_pub_sub_sensor
- airflow.contrib.sensors.sagemaker_base_sensor
- airflow.contrib.sensors.sagemaker_endpoint_sensor
- airflow.contrib.sensors.sagemaker_training_sensor
- airflow.contrib.sensors.sagemaker_transform_sensor
- airflow.contrib.sensors.sagemaker_tuning_sensor
- airflow.contrib.sensors.sftp_sensor
- airflow.contrib.sensors.wasb_sensor
- airflow.contrib.sensors.weekday_sensor
- airflow.dag.base_dag
- airflow.example_dags.example_bash_operator
- airflow.example_dags.example_python_operator
- airflow.exceptions
- airflow.executors
- airflow.executors.base_executor
- airflow.executors.celery_executor
- airflow.executors.dask_executor
- airflow.executors.local_executor
- airflow.executors.sequential_executor
- airflow.hooks
- airflow.hooks.S3_hook
- airflow.hooks.base_hook
- airflow.hooks.dbapi_hook
- airflow.hooks.docker_hook
- airflow.hooks.druid_hook
- airflow.hooks.hdfs_hook
- airflow.hooks.hive_hooks
- airflow.hooks.http_hook
- airflow.hooks.jdbc_hook
- airflow.hooks.mssql_hook
- airflow.hooks.mysql_hook
- airflow.hooks.oracle_hook
- airflow.hooks.pig_hook
- airflow.hooks.postgres_hook
- airflow.hooks.presto_hook
- airflow.hooks.samba_hook
- airflow.hooks.slack_hook
- airflow.hooks.sqlite_hook
- airflow.hooks.webhdfs_hook
- airflow.hooks.zendesk_hook
- airflow.lineage
- airflow.macros
- airflow.models
- airflow.models.base
- airflow.models.connection
- airflow.models.dagpickle
- airflow.models.errors
- airflow.models.kubernetes
- airflow.models.log
- airflow.models.skipmixin
- airflow.models.slamiss
- airflow.models.taskfail
- airflow.models.taskreschedule
- airflow.operators
- airflow.operators.bash_operator
- airflow.operators.check_operator
- airflow.operators.dagrun_operator
- airflow.operators.docker_operator
- airflow.operators.druid_check_operator
- airflow.operators.dummy_operator
- airflow.operators.email_operator
- airflow.operators.generic_transfer
- airflow.operators.hive_operator
- airflow.operators.hive_stats_operator
- airflow.operators.hive_to_druid
- airflow.operators.hive_to_mysql
- airflow.operators.hive_to_samba_operator
- airflow.operators.http_operator
- airflow.operators.jdbc_operator
- airflow.operators.latest_only_operator
- airflow.operators.mssql_operator
- airflow.operators.mssql_to_hive
- airflow.operators.mysql_operator
- airflow.operators.mysql_to_hive
- airflow.operators.oracle_operator
- airflow.operators.pig_operator
- airflow.operators.postgres_operator
- airflow.operators.presto_check_operator
- airflow.operators.presto_to_mysql
- airflow.operators.python_operator
- airflow.operators.redshift_to_s3_operator
- airflow.operators.s3_file_transform_operator
- airflow.operators.s3_to_hive_operator
- airflow.operators.s3_to_redshift_operator
- airflow.operators.sensors
- airflow.operators.slack_operator
- airflow.operators.sqlite_operator
- airflow.operators.subdag_operator
- airflow.sensors
- airflow.sensors.base_sensor_operator
- airflow.sensors.external_task_sensor
- airflow.sensors.hdfs_sensor
- airflow.sensors.hive_partition_sensor
- airflow.sensors.http_sensor
- airflow.sensors.metastore_partition_sensor
- airflow.sensors.named_hive_partition_sensor
- airflow.sensors.s3_key_sensor
- airflow.sensors.s3_prefix_sensor
- airflow.sensors.sql_sensor
- airflow.sensors.time_delta_sensor
- airflow.sensors.time_sensor
- airflow.sensors.web_hdfs_sensor
- airflow.ti_deps.dep_context
- airflow.ti_deps.deps.not_in_retry_period_dep
- airflow.ti_deps.deps.prev_dagrun_dep
- airflow.ti_deps.deps.trigger_rule_dep
- airflow.utils.dag_processing
- airflow.utils.dates
- airflow.utils.db
- airflow.utils.decorators
- airflow.utils.email
- airflow.utils.helpers
- airflow.utils.log.logging_mixin
- airflow.utils.net
- airflow.utils.operator_resources
- airflow.utils.sqlalchemy
- airflow.utils.state
- airflow.utils.timeout
- airflow.utils.trigger_rule
- airflow.utils.weight_rule