Index

A

acknowledge() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) add_task() (airflow.models.DAG method) add_tasks() (airflow.models.DAG method) AdlsToGoogleCloudStorageOperator (class in airflow.contrib.operators.adls_to_gcs), [1] aggregate() (airflow.contrib.hooks.mongo_hook.MongoHook method) airflow.hooks.hive_hooks (module) airflow.macros (module) airflow.models (module) allocate_ids() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] are_dependencies_met() (airflow.models.TaskInstance method) are_dependents_done() (airflow.models.TaskInstance method) AthenaSensor (class in airflow.contrib.sensors.aws_athena_sensor) await() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) AWSAthenaHook (class in airflow.contrib.hooks.aws_athena_hook)

AWSAthenaOperator (class in airflow.contrib.operators.aws_athena_operator) AWSBatchOperator (class in airflow.contrib.operators.awsbatch_operator), [1] AwsDynamoDBHook (class in airflow.contrib.hooks.aws_dynamodb_hook) AwsFirehoseHook (class in airflow.contrib.hooks.aws_firehose_hook) AwsGlueCatalogHook (class in airflow.contrib.hooks.aws_glue_catalog_hook) AwsGlueCatalogPartitionSensor (class in airflow.contrib.sensors.aws_glue_catalog_partition_sensor) AwsHook (class in airflow.contrib.hooks.aws_hook) AwsLambdaHook (class in airflow.contrib.hooks.aws_lambda_hook) AwsRedshiftClusterSensor (class in airflow.contrib.sensors.aws_redshift_cluster_sensor), [1] AzureCosmosDBHook (class in airflow.contrib.hooks.azure_cosmos_hook), [1] AzureCosmosDocumentSensor (class in airflow.contrib.sensors.azure_cosmos_sensor), [1] AzureCosmosInsertDocumentOperator (class in airflow.contrib.operators.azure_cosmos_operator), [1] AzureDataLakeHook (class in airflow.contrib.hooks.azure_data_lake_hook), [1] AzureDataLakeStorageListOperator (class in airflow.contrib.operators.adls_list_operator), [1] AzureFileShareHook (class in airflow.contrib.hooks.azure_fileshare_hook), [1]

B

bag_dag() (airflow.models.DagBag method) BaseOperator (class in airflow.models), [1] BaseSensorOperator (class in airflow.sensors.base_sensor_operator) BashOperator (class in airflow.operators.bash_operator) BashSensor (class in airflow.contrib.sensors.bash_sensor) begin_transaction() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] BigQueryCheckOperator (class in airflow.contrib.operators.bigquery_check_operator), [1] BigQueryCreateEmptyDatasetOperator (class in airflow.contrib.operators.bigquery_operator), [1] BigQueryCreateEmptyTableOperator (class in airflow.contrib.operators.bigquery_operator), [1] BigQueryCreateExternalTableOperator (class in airflow.contrib.operators.bigquery_operator), [1] BigQueryDeleteDatasetOperator (class in airflow.contrib.operators.bigquery_operator), [1] BigQueryGetDataOperator (class in airflow.contrib.operators.bigquery_get_data), [1] BigQueryHook (class in airflow.contrib.hooks.bigquery_hook), [1]

BigQueryIntervalCheckOperator (class in airflow.contrib.operators.bigquery_check_operator), [1] BigQueryOperator (class in airflow.contrib.operators.bigquery_operator), [1] BigQueryTableDeleteOperator (class in airflow.contrib.operators.bigquery_table_delete_operator), [1] BigQueryTableSensor (class in airflow.contrib.sensors.bigquery_sensor) BigQueryToBigQueryOperator (class in airflow.contrib.operators.bigquery_to_bigquery), [1] BigQueryToCloudStorageOperator (class in airflow.contrib.operators.bigquery_to_gcs), [1] BigQueryValueCheckOperator (class in airflow.contrib.operators.bigquery_check_operator), [1] BranchPythonOperator (class in airflow.operators.python_operator) bulk_dump() (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.mysql_hook.MySqlHook method) (airflow.hooks.postgres_hook.PostgresHook method) bulk_load() (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.mysql_hook.MySqlHook method) (airflow.hooks.postgres_hook.PostgresHook method)

C

call() (airflow.hooks.zendesk_hook.ZendeskHook method) CassandraHook (class in airflow.contrib.hooks.cassandra_hook) CassandraRecordSensor (class in airflow.contrib.sensors.cassandra_record_sensor) CassandraTableSensor (class in airflow.contrib.sensors.cassandra_table_sensor) CassandraToGoogleCloudStorageOperator (class in airflow.contrib.operators.cassandra_to_gcs) CeleryExecutor (class in airflow.executors.celery_executor) Chart (class in airflow.models) check_for_blob() (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] check_for_bucket() (airflow.hooks.S3_hook.S3Hook method), [1] check_for_directory() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] check_for_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method), [1] (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] check_for_key() (airflow.hooks.S3_hook.S3Hook method), [1] check_for_named_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method) check_for_partition() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method) (airflow.hooks.hive_hooks.HiveMetastoreHook method) check_for_prefix() (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] (airflow.hooks.S3_hook.S3Hook method), [1] check_for_wildcard_key() (airflow.hooks.S3_hook.S3Hook method), [1] check_query_status() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) check_response() (airflow.hooks.http_hook.HttpHook method) check_s3_url() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] check_status() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] check_training_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] check_training_status_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] check_tuning_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] CheckOperator (class in airflow.operators.check_operator) cleanup_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) clear() (airflow.models.BaseOperator method), [1] (airflow.models.DAG method) clear_not_launched_queued_tasks() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) clear_task_instances() (in module airflow.models) clear_xcom_data() (airflow.models.TaskInstance method) cli() (airflow.models.DAG method) close_conn() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) closest_ds_partition() (in module airflow.macros.hive) CloudantHook (class in airflow.contrib.hooks.cloudant_hook) CloudSqlDatabaseHook (class in airflow.contrib.hooks.gcp_sql_hook) CloudSqlHook (class in airflow.contrib.hooks.gcp_sql_hook) CloudSqlInstanceCreateOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudSqlInstanceDatabaseCreateOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudSqlInstanceDatabaseDeleteOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudSqlInstanceDatabasePatchOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudSqlInstanceDeleteOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudSqlInstanceExportOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudSqlInstanceImportOperator (class in airflow.contrib.operators.gcp_sql_operator)

CloudSqlInstancePatchOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudSqlProxyRunner (class in airflow.contrib.hooks.gcp_sql_hook) CloudSqlQueryOperator (class in airflow.contrib.operators.gcp_sql_operator) cluster_status() (airflow.contrib.hooks.redshift_hook.RedshiftHook method), [1] collect_dags() (airflow.models.DagBag method) command() (airflow.models.TaskInstance method) command_as_list() (airflow.models.TaskInstance method) commit() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] concurrency_reached (airflow.models.DAG attribute) configure_s3_resources() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] Connection (class in airflow.models) construct_api_call_params() (airflow.operators.slack_operator.SlackAPIOperator method) (airflow.operators.slack_operator.SlackAPIPostOperator method) construct_ingest_query() (airflow.operators.hive_to_druid.HiveToDruidTransfer method) convert_map_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) convert_tuple_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) convert_types() (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class method) convert_user_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) copy() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] copy_expert() (airflow.hooks.postgres_hook.PostgresHook method) copy_object() (airflow.hooks.S3_hook.S3Hook method), [1] create() (airflow.models.DagStat static method) create_bucket() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] (airflow.hooks.S3_hook.S3Hook method), [1] create_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method), [1] create_collection() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] create_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) create_dagrun() (airflow.models.DAG method) create_database() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) create_directory() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) create_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] create_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] create_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) create_job() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] create_job_flow() (airflow.contrib.hooks.emr_hook.EmrHook method), [1] create_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] create_new_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) create_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) create_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) create_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] create_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] create_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] create_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] current_state() (airflow.models.TaskInstance method)

D

dag (airflow.models.BaseOperator attribute), [1] DAG (class in airflow.models) DagBag (class in airflow.models) dagbag_report() (airflow.models.DagBag method) DagModel (class in airflow.models) DagPickle (class in airflow.models) DagRun (class in airflow.models) DagStat (class in airflow.models) DatabricksHook (class in airflow.contrib.hooks.databricks_hook) DatabricksSubmitRunOperator (class in airflow.contrib.operators.databricks_operator), [1] DatadogHook (class in airflow.contrib.hooks.datadog_hook) DatadogSensor (class in airflow.contrib.sensors.datadog_sensor) DataFlowHook (class in airflow.contrib.hooks.gcp_dataflow_hook), [1] DataFlowJavaOperator (class in airflow.contrib.operators.dataflow_operator), [1] DataFlowPythonOperator (class in airflow.contrib.operators.dataflow_operator), [1] DataflowTemplateOperator (class in airflow.contrib.operators.dataflow_operator), [1] DataprocClusterCreateOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataprocClusterDeleteOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataprocClusterScaleOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataProcHadoopOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataProcHiveOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataProcHook (class in airflow.contrib.hooks.gcp_dataproc_hook) DataProcPigOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataProcPySparkOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataProcSparkOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataProcSparkSqlOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataprocWorkflowTemplateBaseOperator (class in airflow.contrib.operators.dataproc_operator) DataprocWorkflowTemplateInstantiateInlineOperator (class in airflow.contrib.operators.dataproc_operator), [1] DataprocWorkflowTemplateInstantiateOperator (class in airflow.contrib.operators.dataproc_operator), [1] DatastoreExportOperator (class in airflow.contrib.operators.datastore_export_operator), [1] DatastoreHook (class in airflow.contrib.hooks.datastore_hook), [1] DatastoreImportOperator (class in airflow.contrib.operators.datastore_import_operator), [1] DayOfWeekSensor (class in airflow.contrib.sensors.weekday_sensor) db() (airflow.contrib.hooks.cloudant_hook.CloudantHook method) DbApiHook (class in airflow.hooks.dbapi_hook) deactivate_stale_dags() (airflow.models.DAG static method) deactivate_unknown_dags() (airflow.models.DAG static method) delete() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] delete_cluster() (airflow.contrib.hooks.redshift_hook.RedshiftHook method), [1] delete_collection() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] delete_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) delete_database() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)

delete_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) delete_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] delete_file() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] delete_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) delete_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) delete_objects() (airflow.hooks.S3_hook.S3Hook method), [1] delete_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] delete_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) delete_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) delete_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] deps (airflow.models.BaseOperator attribute), [1] (airflow.sensors.base_sensor_operator.BaseSensorOperator attribute) describe_cluster_snapshots() (airflow.contrib.hooks.redshift_hook.RedshiftHook method), [1] describe_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) describe_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] describe_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] describe_model() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] describe_object() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) describe_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] describe_training_job_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] describe_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] describe_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] DiscordWebhookHook (class in airflow.contrib.hooks.discord_webhook_hook) DiscordWebhookOperator (class in airflow.contrib.operators.discord_webhook_operator) does_collection_exist() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] does_database_exist() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] download() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] download_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method), [1] download_mail_attachments() (airflow.contrib.hooks.imap_hook.ImapHook method) downstream_list (airflow.models.BaseOperator attribute), [1] DruidCheckOperator (class in airflow.operators.druid_check_operator) DruidDbApiHook (class in airflow.hooks.druid_hook) DruidHook (class in airflow.hooks.druid_hook) DruidOperator (class in airflow.contrib.operators.druid_operator) ds_add() (in module airflow.macros) ds_format() (in module airflow.macros) DummyOperator (class in airflow.operators.dummy_operator)

E

ECSOperator (class in airflow.contrib.operators.ecs_operator), [1] EmailOperator (class in airflow.operators.email_operator) EmrAddStepsOperator (class in airflow.contrib.operators.emr_add_steps_operator), [1] EmrBaseSensor (class in airflow.contrib.sensors.emr_base_sensor) EmrCreateJobFlowOperator (class in airflow.contrib.operators.emr_create_job_flow_operator), [1] EmrHook (class in airflow.contrib.hooks.emr_hook), [1] EmrJobFlowSensor (class in airflow.contrib.sensors.emr_job_flow_sensor) EmrStepSensor (class in airflow.contrib.sensors.emr_step_sensor) EmrTerminateJobFlowOperator (class in airflow.contrib.operators.emr_terminate_job_flow_operator), [1] end() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.sequential_executor.SequentialExecutor method) error() (airflow.models.TaskInstance method) execute() (airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook method) (airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook method) (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method) (airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator method), [1] (airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator method) (airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator method), [1] (airflow.contrib.operators.file_to_wasb.FileToWasbOperator method), [1] (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator method) (airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator method) (airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator method) (airflow.contrib.operators.spark_sql_operator.SparkSqlOperator method) (airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator method) (airflow.contrib.operators.sqoop_operator.SqoopOperator method) (airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method) (airflow.models.BaseOperator method), [1] (airflow.operators.bash_operator.BashOperator method) (airflow.operators.slack_operator.SlackAPIOperator method)

execute_async() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.sequential_executor.SequentialExecutor method) exists() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] expand_role() (airflow.contrib.hooks.aws_hook.AwsHook method) export_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) export_table() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) export_to_storage_bucket() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] ExternalTaskSensor (class in airflow.sensors.external_task_sensor) extra_dejson (airflow.models.Connection attribute)

F

fallback_to_default_project_id() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook static method), [1] filepath (airflow.models.DAG attribute) FileSensor (class in airflow.contrib.sensors.file_sensor) FileToGoogleCloudStorageOperator (class in airflow.contrib.operators.file_to_gcs), [1] FileToWasbOperator (class in airflow.contrib.operators.file_to_wasb), [1] filter_for_filesize() (airflow.sensors.hdfs_sensor.HdfsSensor static method) filter_for_ignored_ext() (airflow.sensors.hdfs_sensor.HdfsSensor static method) find() (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.models.DagRun static method)

find_for_task_instance() (airflow.models.TaskReschedule static method) folder (airflow.models.DAG attribute) following_schedule() (airflow.models.DAG method) free_reserved_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) FSHook (class in airflow.contrib.hooks.fs_hook) FTPHook (class in airflow.contrib.hooks.ftp_hook) FTPSensor (class in airflow.contrib.sensors.ftp_sensor) FTPSHook (class in airflow.contrib.hooks.ftp_hook) FTPSSensor (class in airflow.contrib.sensors.ftp_sensor)

G

GceBaseOperator (class in airflow.contrib.operators.gcp_compute_operator) GceHook (class in airflow.contrib.hooks.gcp_compute_hook) GceInstanceGroupManagerUpdateTemplateOperator (class in airflow.contrib.operators.gcp_compute_operator) GceInstanceStartOperator (class in airflow.contrib.operators.gcp_compute_operator) GceInstanceStopOperator (class in airflow.contrib.operators.gcp_compute_operator) GceInstanceTemplateCopyOperator (class in airflow.contrib.operators.gcp_compute_operator) GceSetMachineTypeOperator (class in airflow.contrib.operators.gcp_compute_operator) GcfFunctionDeleteOperator (class in airflow.contrib.operators.gcp_function_operator) GcfFunctionDeployOperator (class in airflow.contrib.operators.gcp_function_operator) GcfHook (class in airflow.contrib.hooks.gcp_function_hook) GCPTransferServiceHook (class in airflow.contrib.hooks.gcp_transfer_hook), [1] generate_command() (airflow.models.TaskInstance static method) GenericTransfer (class in airflow.operators.generic_transfer) get_active_runs() (airflow.models.DAG method) get_autocommit() (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.mysql_hook.MySqlHook method) get_available_fields() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) get_bucket() (airflow.hooks.S3_hook.S3Hook method), [1] get_collection() (airflow.contrib.hooks.mongo_hook.MongoHook method) get_conn() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) (airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method) (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method) (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method), [1] (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] (airflow.contrib.hooks.bigquery_hook.BigQueryHook method), [1] (airflow.contrib.hooks.cassandra_hook.CassandraHook method) (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.ftp_hook.FTPSHook method) (airflow.contrib.hooks.gcp_compute_hook.GceHook method) (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method), [1] (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) (airflow.contrib.hooks.gcp_function_hook.GcfHook method) (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method), [1] (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.contrib.hooks.redis_hook.RedisHook method) (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] (airflow.contrib.hooks.sftp_hook.SFTPHook method) (airflow.contrib.hooks.snowflake_hook.SnowflakeHook method) (airflow.contrib.hooks.ssh_hook.SSHHook method) (airflow.contrib.hooks.vertica_hook.VerticaHook method) (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) (airflow.hooks.hdfs_hook.HDFSHook method) (airflow.hooks.http_hook.HttpHook method) (airflow.hooks.mssql_hook.MsSqlHook method) (airflow.hooks.mysql_hook.MySqlHook method) (airflow.hooks.postgres_hook.PostgresHook method) (airflow.hooks.presto_hook.PrestoHook method) (airflow.hooks.sqlite_hook.SqliteHook method) get_context_from_env_var() (in module airflow.hooks.hive_hooks) get_crc32c() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] get_credentials() (airflow.contrib.hooks.aws_hook.AwsHook method) get_cursor() (airflow.hooks.dbapi_hook.DbApiHook method) get_dag() (airflow.models.DagBag method) (airflow.models.DagRun method) get_dagrun() (airflow.models.DAG method) (airflow.models.TaskInstance method) get_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) get_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) get_databases() (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_db_hook() (airflow.operators.druid_check_operator.DruidCheckOperator method) get_direct_relative_ids() (airflow.models.BaseOperator method), [1] get_direct_relatives() (airflow.models.BaseOperator method), [1] get_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] get_documents() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] get_fernet() (in module airflow.models) get_file() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] get_file_to_stream() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1]

get_first() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.presto_hook.PrestoHook method) (airflow.operators.druid_check_operator.DruidCheckOperator method) get_flat_relative_ids() (airflow.models.BaseOperator method), [1] get_flat_relatives() (airflow.models.BaseOperator method), [1] get_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) get_hook() (airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor method) get_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) get_instance_group_manager() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) get_instance_template() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) get_jobs_id() (airflow.contrib.hooks.qubole_hook.QuboleHook method) get_key() (airflow.hooks.S3_hook.S3Hook method), [1] get_last_dagrun() (airflow.models.DAG method) get_latest_runs() (airflow.models.DagRun class method) get_log() (airflow.contrib.hooks.qubole_hook.QuboleHook method) get_log_conn() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] get_many() (airflow.models.XCom class method) get_md5hash() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] get_metastore_client() (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_mod_time() (airflow.contrib.hooks.ftp_hook.FTPHook method) get_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] get_num_active_runs() (airflow.models.DAG method) get_num_task_instances() (airflow.models.DAG static method) get_object_from_salesforce() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) get_one() (airflow.models.XCom class method) get_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] get_pandas_df() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method), [1] (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) (airflow.hooks.hive_hooks.HiveServer2Hook method) (airflow.hooks.presto_hook.PrestoHook method) get_partitions() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method) (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_previous_dagrun() (airflow.models.DagRun method) get_previous_scheduled_dagrun() (airflow.models.DagRun method) get_proxy_version() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) get_query_results() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) get_records() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.hive_hooks.HiveServer2Hook method) (airflow.hooks.presto_hook.PrestoHook method) get_results() (airflow.contrib.hooks.qubole_hook.QuboleHook method) (airflow.hooks.hive_hooks.HiveServer2Hook method) get_run() (airflow.models.DagRun static method) get_run_dates() (airflow.models.DAG method) get_service() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method), [1] get_session() (airflow.contrib.hooks.aws_hook.AwsHook method) get_size() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] get_socket_path() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) get_sqlproxy_runner() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) get_table() (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_tables() (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_task_instance() (airflow.models.DagRun method) get_task_instances() (airflow.models.BaseOperator method), [1] (airflow.models.DagRun method) get_template_env() (airflow.models.DAG method) get_tunnel() (airflow.contrib.hooks.ssh_hook.SSHHook method) get_uri() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.contrib.hooks.snowflake_hook.SnowflakeHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) get_wildcard_key() (airflow.hooks.S3_hook.S3Hook method), [1] GoogleCloudBaseHook (class in airflow.contrib.hooks.gcp_api_base_hook), [1] GoogleCloudStorageBucketCreateAclEntryOperator (class in airflow.contrib.operators.gcs_acl_operator) GoogleCloudStorageCreateBucketOperator (class in airflow.contrib.operators.gcs_operator), [1] GoogleCloudStorageDownloadOperator (class in airflow.contrib.operators.gcs_download_operator), [1] GoogleCloudStorageHook (class in airflow.contrib.hooks.gcs_hook), [1] GoogleCloudStorageListOperator (class in airflow.contrib.operators.gcs_list_operator), [1] GoogleCloudStorageObjectCreateAclEntryOperator (class in airflow.contrib.operators.gcs_acl_operator) GoogleCloudStorageObjectSensor (class in airflow.contrib.sensors.gcs_sensor) GoogleCloudStorageObjectUpdatedSensor (class in airflow.contrib.sensors.gcs_sensor) GoogleCloudStoragePrefixSensor (class in airflow.contrib.sensors.gcs_sensor) GoogleCloudStorageToBigQueryOperator (class in airflow.contrib.operators.gcs_to_bq), [1] GoogleCloudStorageToGoogleCloudStorageOperator (class in airflow.contrib.operators.gcs_to_gcs), [1] GoogleCloudStorageToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.gcs_to_gcs_transfer_operator), [1] GoogleCloudStorageToS3Operator (class in airflow.contrib.operators.gcs_to_s3)

H

handle_callback() (airflow.models.DAG method) has_dag() (airflow.models.BaseOperator method), [1] has_mail_attachment() (airflow.contrib.hooks.imap_hook.ImapHook method) HDFSHook (class in airflow.hooks.hdfs_hook) HdfsSensor (class in airflow.sensors.hdfs_sensor) HdfsSensorFolder (class in airflow.contrib.sensors.hdfs_sensor) HdfsSensorRegex (class in airflow.contrib.sensors.hdfs_sensor) HipChatAPIOperator (class in airflow.contrib.operators.hipchat_operator) HipChatAPISendRoomNotificationOperator (class in airflow.contrib.operators.hipchat_operator) Hive2SambaOperator (class in airflow.operators.hive_to_samba_operator)

HiveCliHook (class in airflow.hooks.hive_hooks) HiveMetastoreHook (class in airflow.hooks.hive_hooks) HiveOperator (class in airflow.operators.hive_operator) HivePartitionSensor (class in airflow.sensors.hive_partition_sensor) HiveServer2Hook (class in airflow.hooks.hive_hooks) HiveStatsCollectionOperator (class in airflow.operators.hive_stats_operator) HiveToDruidTransfer (class in airflow.operators.hive_to_druid) HiveToDynamoDBTransferOperator (class in airflow.contrib.operators.hive_to_dynamodb) HiveToMySqlTransfer (class in airflow.operators.hive_to_mysql) HttpHook (class in airflow.hooks.http_hook) HttpSensor (class in airflow.sensors.http_sensor)

I

ImapHook (class in airflow.contrib.hooks.imap_hook) import_from_storage_bucket() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] import_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) import_query() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) import_table() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) ImportError (class in airflow.models) init_on_load() (airflow.models.TaskInstance method) init_run_context() (airflow.models.TaskInstance method) insert_bucket_acl() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] insert_documents() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] insert_instance_template() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) insert_many() (airflow.contrib.hooks.mongo_hook.MongoHook method) insert_object_acl() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1]

insert_one() (airflow.contrib.hooks.mongo_hook.MongoHook method) insert_rows() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method), [1] (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) (airflow.hooks.presto_hook.PrestoHook method) IntervalCheckOperator (class in airflow.operators.check_operator) InvalidFernetToken invoke_lambda() (airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook method) is_eligible_to_retry() (airflow.models.TaskInstance method) is_fixed_time_schedule() (airflow.models.DAG method) is_paused (airflow.models.DAG attribute) is_premature (airflow.models.TaskInstance attribute) is_updated_after() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1]

J

JiraHook (class in airflow.contrib.hooks.jira_hook)

JiraOperator (class in airflow.contrib.operators.jira_operator) JiraSensor (class in airflow.contrib.sensors.jira_sensor)

K

key (airflow.models.TaskInstance attribute) key_exists() (airflow.contrib.hooks.redis_hook.RedisHook method) kill() (airflow.contrib.hooks.qubole_hook.QuboleHook method) kill_zombies() (airflow.models.DagBag method) KnownEvent (class in airflow.models)

KnownEventType (class in airflow.models) KubeResourceVersion (class in airflow.models) KubernetesExecutor (class in airflow.contrib.executors.kubernetes_executor) KubernetesPodOperator (class in airflow.contrib.operators.kubernetes_pod_operator), [1] KubeWorkerIdentifier (class in airflow.models)

L

latest_execution_date (airflow.models.DAG attribute) LatestOnlyOperator (class in airflow.operators.latest_only_operator) list() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] list_directories_and_files() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] list_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) list_keys() (airflow.hooks.S3_hook.S3Hook method), [1] list_prefixes() (airflow.hooks.S3_hook.S3Hook method), [1] list_versions() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] load_bytes() (airflow.hooks.S3_hook.S3Hook method), [1] load_df() (airflow.hooks.hive_hooks.HiveCliHook method) load_file() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] (airflow.hooks.S3_hook.S3Hook method), [1] (airflow.hooks.hive_hooks.HiveCliHook method)

load_file_obj() (airflow.hooks.S3_hook.S3Hook method), [1] load_stream() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] load_string() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method), [1] (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] (airflow.hooks.S3_hook.S3Hook method), [1] LocalExecutor (class in airflow.executors.local_executor) Log (class in airflow.models) log_stream() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] lookup() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1]

M

make_query() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) max_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method) (in module airflow.macros.hive) MesosExecutor (class in airflow.contrib.executors.mesos_executor) MetastorePartitionSensor (class in airflow.sensors.metastore_partition_sensor) MLEngineBatchPredictionOperator (class in airflow.contrib.operators.mlengine_operator), [1] MLEngineHook (class in airflow.contrib.hooks.gcp_mlengine_hook), [1] MLEngineModelOperator (class in airflow.contrib.operators.mlengine_operator), [1] MLEngineTrainingOperator (class in airflow.contrib.operators.mlengine_operator), [1] MLEngineVersionOperator (class in airflow.contrib.operators.mlengine_operator), [1]

MongoHook (class in airflow.contrib.hooks.mongo_hook) MongoToS3Operator (class in airflow.contrib.operators.mongo_to_s3) MsSqlHook (class in airflow.hooks.mssql_hook) MsSqlOperator (class in airflow.operators.mssql_operator) MsSqlToHiveTransfer (class in airflow.operators.mssql_to_hive) multi_stream_iter() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] MySqlHook (class in airflow.hooks.mysql_hook) MySqlOperator (class in airflow.operators.mysql_operator) MySqlToGoogleCloudStorageOperator (class in airflow.contrib.operators.mysql_to_gcs), [1] MySqlToHiveTransfer (class in airflow.operators.mysql_to_hive)

N

NamedHivePartitionSensor (class in airflow.sensors.named_hive_partition_sensor) next_retry_datetime() (airflow.models.TaskInstance method)

normalize_schedule() (airflow.models.DAG method) NullFernet (class in airflow.models)

O

on_kill() (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method) (airflow.models.BaseOperator method), [1]

open_slots() (airflow.models.Pool method) OpenFaasHook (class in airflow.contrib.hooks.openfaas_hook)

P

patch_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) patch_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) patch_instance_group_manager() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) PigCliHook (class in airflow.hooks.pig_hook) PigOperator (class in airflow.operators.pig_operator) PinotDbApiHook (class in airflow.contrib.hooks.pinot_hook) poke() (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor method) (airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor method) (airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor method), [1] (airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor method), [1] (airflow.contrib.sensors.bash_sensor.BashSensor method) (airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor method) (airflow.contrib.sensors.cassandra_record_sensor.CassandraRecordSensor method) (airflow.contrib.sensors.cassandra_table_sensor.CassandraTableSensor method) (airflow.contrib.sensors.datadog_sensor.DatadogSensor method) (airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor method) (airflow.contrib.sensors.file_sensor.FileSensor method) (airflow.contrib.sensors.ftp_sensor.FTPSensor method) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor method) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor method) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor method) (airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder method) (airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex method) (airflow.contrib.sensors.jira_sensor.JiraSensor method) (airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method) (airflow.contrib.sensors.python_sensor.PythonSensor method) (airflow.contrib.sensors.qubole_sensor.QuboleSensor method) (airflow.contrib.sensors.redis_key_sensor.RedisKeySensor method) (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method) (airflow.contrib.sensors.sftp_sensor.SFTPSensor method) (airflow.contrib.sensors.wasb_sensor.WasbBlobSensor method), [1] (airflow.contrib.sensors.wasb_sensor.WasbPrefixSensor method) (airflow.contrib.sensors.weekday_sensor.DayOfWeekSensor method) (airflow.sensors.base_sensor_operator.BaseSensorOperator method) (airflow.sensors.external_task_sensor.ExternalTaskSensor method) (airflow.sensors.hdfs_sensor.HdfsSensor method) (airflow.sensors.hive_partition_sensor.HivePartitionSensor method) (airflow.sensors.http_sensor.HttpSensor method) (airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor method) (airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor method) (airflow.sensors.s3_key_sensor.S3KeySensor method) (airflow.sensors.s3_prefix_sensor.S3PrefixSensor method) (airflow.sensors.sql_sensor.SqlSensor method) (airflow.sensors.time_delta_sensor.TimeDeltaSensor method) (airflow.sensors.time_sensor.TimeSensor method) (airflow.sensors.web_hdfs_sensor.WebHdfsSensor method)

poll_operation_until_done() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] poll_query_status() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) Pool (class in airflow.models) pool_full() (airflow.models.TaskInstance method) Popen() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) post_event() (airflow.contrib.hooks.datadog_hook.DatadogHook method) post_execute() (airflow.models.BaseOperator method), [1] PostgresHook (class in airflow.hooks.postgres_hook) PostgresOperator (class in airflow.operators.postgres_operator) PostgresToGoogleCloudStorageOperator (class in airflow.contrib.operators.postgres_to_gcs_operator) pre_execute() (airflow.models.BaseOperator method), [1] prepare_request() (airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method) (airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator method) prepare_template() (airflow.models.BaseOperator method), [1] PrestoCheckOperator (class in airflow.operators.presto_check_operator) PrestoHook (class in airflow.hooks.presto_hook) PrestoIntervalCheckOperator (class in airflow.operators.presto_check_operator) PrestoToMySqlTransfer (class in airflow.operators.presto_to_mysql) PrestoValueCheckOperator (class in airflow.operators.presto_check_operator) previous_schedule() (airflow.models.DAG method) previous_ti (airflow.models.TaskInstance attribute) process_file() (airflow.models.DagBag method) publish() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) PubSubHook (class in airflow.contrib.hooks.gcp_pubsub_hook) PubSubPublishOperator (class in airflow.contrib.operators.pubsub_operator) PubSubPullSensor (class in airflow.contrib.sensors.pubsub_sensor) PubSubSubscriptionCreateOperator (class in airflow.contrib.operators.pubsub_operator) PubSubSubscriptionDeleteOperator (class in airflow.contrib.operators.pubsub_operator) PubSubTopicCreateOperator (class in airflow.contrib.operators.pubsub_operator) PubSubTopicDeleteOperator (class in airflow.contrib.operators.pubsub_operator) pull() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) put_records() (airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method) PythonOperator (class in airflow.operators.python_operator) PythonSensor (class in airflow.contrib.sensors.python_sensor) PythonVirtualenvOperator (class in airflow.operators.python_operator)

Q

QuboleCheckOperator (class in airflow.contrib.operators.qubole_check_operator), [1] QuboleFileSensor (class in airflow.contrib.sensors.qubole_sensor) QuboleHook (class in airflow.contrib.hooks.qubole_hook) QuboleOperator (class in airflow.contrib.operators.qubole_operator), [1]

QubolePartitionSensor (class in airflow.contrib.sensors.qubole_sensor) QuboleSensor (class in airflow.contrib.sensors.qubole_sensor) QuboleValueCheckOperator (class in airflow.contrib.operators.qubole_check_operator), [1] query_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method) queued_slots() (airflow.models.Pool method)

R

random() (in module airflow.macros) read_file() (airflow.contrib.hooks.wasb_hook.WasbHook method), [1] read_key() (airflow.hooks.S3_hook.S3Hook method), [1] ready_for_retry() (airflow.models.TaskInstance method) record_exists() (airflow.contrib.hooks.cassandra_hook.CassandraHook method) RedisHook (class in airflow.contrib.hooks.redis_hook) RedisKeySensor (class in airflow.contrib.sensors.redis_key_sensor) RedshiftHook (class in airflow.contrib.hooks.redshift_hook), [1] RedshiftToS3Transfer (class in airflow.operators.redshift_to_s3_operator), [1] refresh_from_db() (airflow.models.DagRun method) (airflow.models.TaskInstance method) rename() (airflow.contrib.hooks.ftp_hook.FTPHook method) render_template() (airflow.models.BaseOperator method), [1] render_template_from_field() (airflow.models.BaseOperator method), [1] reserve_free_tcp_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) restore_from_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method), [1] retrieve_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)

retrieve_file() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) retrieve_mail_attachments() (airflow.contrib.hooks.imap_hook.ImapHook method) rewrite() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1] rollback() (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] run() (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.http_hook.HttpHook method) (airflow.hooks.presto_hook.PrestoHook method) (airflow.models.BaseOperator method), [1] (airflow.models.DAG method) run_and_check() (airflow.hooks.http_hook.HttpHook method) run_cli() (airflow.hooks.hive_hooks.HiveCliHook method) (airflow.hooks.pig_hook.PigCliHook method) run_now() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) run_query() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) (airflow.contrib.hooks.datastore_hook.DatastoreHook method), [1] (airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method) run_with_advanced_retry() (airflow.hooks.http_hook.HttpHook method)

S

S3FileTransformOperator (class in airflow.operators.s3_file_transform_operator), [1] S3Hook (class in airflow.hooks.S3_hook), [1] S3KeySensor (class in airflow.sensors.s3_key_sensor) S3ListOperator (class in airflow.contrib.operators.s3_list_operator), [1] S3PrefixSensor (class in airflow.sensors.s3_prefix_sensor) S3ToGoogleCloudStorageOperator (class in airflow.contrib.operators.s3_to_gcs_operator), [1] S3ToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.s3_to_gcs_transfer_operator) S3ToHiveTransfer (class in airflow.operators.s3_to_hive_operator), [1] S3ToRedshiftTransfer (class in airflow.operators.s3_to_redshift_operator), [1] SageMakerBaseOperator (class in airflow.contrib.operators.sagemaker_base_operator) SageMakerBaseSensor (class in airflow.contrib.sensors.sagemaker_base_sensor) SageMakerEndpointConfigOperator (class in airflow.contrib.operators.sagemaker_endpoint_config_operator), [1], [2] SageMakerEndpointOperator (class in airflow.contrib.operators.sagemaker_endpoint_operator), [1], [2] SageMakerEndpointSensor (class in airflow.contrib.sensors.sagemaker_endpoint_sensor) SageMakerHook (class in airflow.contrib.hooks.sagemaker_hook), [1], [2] SageMakerModelOperator (class in airflow.contrib.operators.sagemaker_model_operator), [1], [2] SageMakerTrainingOperator (class in airflow.contrib.operators.sagemaker_training_operator), [1], [2] SageMakerTrainingSensor (class in airflow.contrib.sensors.sagemaker_training_sensor) SageMakerTransformOperator (class in airflow.contrib.operators.sagemaker_transform_operator), [1], [2] SageMakerTransformSensor (class in airflow.contrib.sensors.sagemaker_transform_sensor) SageMakerTuningOperator (class in airflow.contrib.operators.sagemaker_tuning_operator), [1], [2] SageMakerTuningSensor (class in airflow.contrib.sensors.sagemaker_tuning_sensor) SalesforceHook (class in airflow.contrib.hooks.salesforce_hook) SambaHook (class in airflow.hooks.samba_hook) schedule_interval (airflow.models.BaseOperator attribute), [1] Secret (class in airflow.contrib.kubernetes.secret) select_key() (airflow.hooks.S3_hook.S3Hook method), [1] send_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method) SequentialExecutor (class in airflow.executors.sequential_executor) set() (airflow.models.XCom class method) set_autocommit() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.contrib.hooks.snowflake_hook.SnowflakeHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) (airflow.hooks.mssql_hook.MsSqlHook method) (airflow.hooks.mysql_hook.MySqlHook method) set_default_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method), [1] set_dependency() (airflow.models.DAG method) set_dirty() (airflow.models.DagStat static method) set_downstream() (airflow.models.BaseOperator method), [1] set_machine_type() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) set_upstream() (airflow.models.BaseOperator method), [1] setdefault() (airflow.models.Variable class method) SFTPHook (class in airflow.contrib.hooks.sftp_hook) SFTPOperator (class in airflow.contrib.operators.sftp_operator) SFTPSensor (class in airflow.contrib.sensors.sftp_sensor) ShortCircuitOperator (class in airflow.operators.python_operator)

shutdown_cluster() (airflow.contrib.hooks.cassandra_hook.CassandraHook method) sign_in() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) SimpleHttpOperator (class in airflow.operators.http_operator) size() (airflow.models.DagBag method) SlackAPIOperator (class in airflow.operators.slack_operator) SlackAPIPostOperator (class in airflow.operators.slack_operator) SlackHook (class in airflow.hooks.slack_hook) SlackWebhookHook (class in airflow.contrib.hooks.slack_webhook_hook) SlackWebhookOperator (class in airflow.contrib.operators.slack_webhook_operator) SlaMiss (class in airflow.models) SnowflakeHook (class in airflow.contrib.hooks.snowflake_hook) SnowflakeOperator (class in airflow.contrib.operators.snowflake_operator) SparkJDBCHook (class in airflow.contrib.hooks.spark_jdbc_hook) SparkJDBCOperator (class in airflow.contrib.operators.spark_jdbc_operator) SparkSqlHook (class in airflow.contrib.hooks.spark_sql_hook) SparkSqlOperator (class in airflow.contrib.operators.spark_sql_operator) SparkSubmitHook (class in airflow.contrib.hooks.spark_submit_hook) SparkSubmitOperator (class in airflow.contrib.operators.spark_submit_operator) SqliteHook (class in airflow.hooks.sqlite_hook) SqliteOperator (class in airflow.operators.sqlite_operator) SqlSensor (class in airflow.sensors.sql_sensor) SqoopHook (class in airflow.contrib.hooks.sqoop_hook) SqoopOperator (class in airflow.contrib.operators.sqoop_operator) SSHHook (class in airflow.contrib.hooks.ssh_hook) SSHOperator (class in airflow.contrib.operators.ssh_operator) start() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.local_executor.LocalExecutor method) start_instance() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) start_proxy() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) stop_instance() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) stop_proxy() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) stop_query() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) store_file() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) sub_dag() (airflow.models.DAG method) SubDagOperator (class in airflow.operators.subdag_operator) subdags (airflow.models.DAG attribute) submit() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) submit_run() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) sync() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.sequential_executor.SequentialExecutor method) sync_to_db() (airflow.models.DAG method)

T

table_exists() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method), [1] (airflow.contrib.hooks.cassandra_hook.CassandraHook method) (airflow.hooks.hive_hooks.HiveMetastoreHook method) tar_and_s3_upload() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] TaskFail (class in airflow.models) TaskInstance (class in airflow.models) TaskReschedule (class in airflow.models) template_fields (airflow.contrib.sensors.ftp_sensor.FTPSensor attribute) test_cycle() (airflow.models.DAG method) test_hql() (airflow.hooks.hive_hooks.HiveCliHook method)

TimeDeltaSensor (class in airflow.sensors.time_delta_sensor) TimeSensor (class in airflow.sensors.time_sensor) to_csv() (airflow.hooks.hive_hooks.HiveServer2Hook method) topological_sort() (airflow.models.DAG method) transform() (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator static method) tree_view() (airflow.models.DAG method) TriggerDagRunOperator (class in airflow.operators.dagrun_operator) try_number (airflow.models.TaskInstance attribute) type_map() (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator class method), [1] (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class method)

U

update() (airflow.models.DagStat static method) update_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method), [1], [2] update_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) update_state() (airflow.models.DagRun method) upload() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method), [1]

upload_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method), [1] upload_function_zip() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) upsert_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method), [1] upstream_list (airflow.models.BaseOperator attribute), [1] used_slots() (airflow.models.Pool method) User (class in airflow.models)

V

ValueCheckOperator (class in airflow.operators.check_operator) Variable (class in airflow.models) verify_integrity() (airflow.models.DagRun method)

VerticaHook (class in airflow.contrib.hooks.vertica_hook) VerticaOperator (class in airflow.contrib.operators.vertica_operator) VerticaToHiveTransfer (class in airflow.contrib.operators.vertica_to_hive)

W

wait() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) WasbBlobSensor (class in airflow.contrib.sensors.wasb_sensor), [1] WasbHook (class in airflow.contrib.hooks.wasb_hook), [1] WasbPrefixSensor (class in airflow.contrib.sensors.wasb_sensor)

WebHdfsSensor (class in airflow.sensors.web_hdfs_sensor) WinRMHook (class in airflow.contrib.hooks.winrm_hook) WinRMOperator (class in airflow.contrib.operators.winrm_operator) write_batch_data() (airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook method) write_object_to_file() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)

X

XCom (class in airflow.models) xcom_pull() (airflow.models.BaseOperator method), [1] (airflow.models.TaskInstance method)

xcom_push() (airflow.models.BaseOperator method), [1] (airflow.models.TaskInstance method)

Z

ZendeskHook (class in airflow.hooks.zendesk_hook)