• Home
• Index

Index

_

__call__() (airflow.contrib.hooks.databricks_hook._TokenAuth method) __deepcopy__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) __enter__() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.imap_hook.ImapHook method) (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.contrib.hooks.ssh_hook.SSHHook method) (airflow.models.DAG method) (airflow.models.dag.DAG method) __eq__() (airflow.contrib.hooks.databricks_hook.RunState method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) __exit__() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.imap_hook.ImapHook method) (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.contrib.hooks.ssh_hook.SSHHook method) (airflow.models.DAG method) (airflow.models.dag.DAG method) __get_collection_name() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) __get_database_name() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) __get_tls_config() (airflow.operators.docker_operator.DockerOperator method) __get_token() (airflow.hooks.slack_hook.SlackHook method) __getattribute__() (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator method) (airflow.contrib.operators.qubole_operator.QuboleOperator method) __getstate__() (airflow.hooks.hive_hooks.HiveMetastoreHook method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) __handle_rate_limit_exception() (airflow.hooks.zendesk_hook.ZendeskHook method) __hash__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) __login() (airflow.hooks.docker_hook.DockerHook method) __lshift__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) __lt__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) __mapper_args__ (airflow.operators.check_operator.IntervalCheckOperator attribute) (airflow.operators.check_operator.ValueCheckOperator attribute) __metaclass__ (airflow.models.baseoperator.BaseOperatorLink attribute) __ne__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) __NO_DEFAULT_SENTINEL (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) __repr__() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutorConfig method) (airflow.contrib.hooks.databricks_hook.RunState method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.Chart method) (airflow.models.chart.Chart method) (airflow.models.Connection method) (airflow.models.connection.Connection method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.DagModel method) (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.models.KnownEvent method) (airflow.models.knownevent.KnownEvent method) (airflow.models.knownevent.KnownEventType method) (airflow.models.KnownEventType method) (airflow.models.Pool method) (airflow.models.pool.Pool method) (airflow.models.SlaMiss method) (airflow.models.slamiss.SlaMiss method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.models.User method) (airflow.models.user.User method) (airflow.models.Variable method) (airflow.models.variable.Variable method) (airflow.models.XCom method) (airflow.models.xcom.XCom method) (airflow.operators.BaseOperator method) __rlshift__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) __rrshift__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) __rshift__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) __setattr__() (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator method) (airflow.contrib.operators.qubole_operator.QuboleOperator method) __setstate__() (airflow.hooks.hive_hooks.HiveMetastoreHook method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) __table_args__ (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) __tablename__ (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) (airflow.models.knownevent.KnownEventType attribute) (airflow.models.KnownEventType attribute) (airflow.models.KubeResourceVersion attribute) (airflow.models.kubernetes.KubeResourceVersion attribute) (airflow.models.kubernetes.KubeWorkerIdentifier attribute) (airflow.models.KubeWorkerIdentifier attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.User attribute) (airflow.models.user.User attribute) (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) _add_tags() (airflow.contrib.hooks.qubole_hook.QuboleHook static method) _api_resource_configs_duplication_check() (in module airflow.contrib.hooks.bigquery_hook) _append_label() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook static method) _apply_to_instance() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) _authorize() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook method) _b64decode() (in module airflow.contrib.hooks.gcp_kms_hook) _b64encode() (in module airflow.contrib.hooks.gcp_kms_hook) _base_operator_shallow_copy_attrs (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) _bind_parameters() (in module airflow.contrib.hooks.bigquery_hook) _bq_cast() (in module airflow.contrib.hooks.bigquery_hook) _build_cluster_data() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _build_cmd() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook static method) _build_command_line_parameters() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) _build_dataflow_job_name() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook static method) _build_discord_payload() (airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook method) _build_field_list() (airflow.contrib.hooks.salesforce_hook.SalesforceHook static method) _build_gce_cluster_config() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _build_jdbc_application_arguments() (airflow.contrib.hooks.spark_jdbc_hook.SparkJDBCHook method) _build_lifecycle_config() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _build_message() (airflow.contrib.hooks.dingding_hook.DingdingHook method) _build_opsgenie_payload() (airflow.contrib.operators.opsgenie_alert_operator.OpsgenieAlertOperator method) _build_scale_cluster_data() (airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator method) _build_slack_message() (airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook method) _build_spark_driver_kill_command() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _build_spark_submit_command() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _build_track_driver_status_command() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _change_state() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) _check_and_change_state_before_execution() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) _check_done() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcOperation method) _check_for_error() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook static method) _check_global_operation_status() (airflow.contrib.hooks.gcp_compute_hook.GceHook static method) _check_if_db_exists() (airflow.contrib.operators.gcp_sql_operator.CloudSqlBaseOperator method) _check_if_function_exists() (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) _check_if_instance_exists() (airflow.contrib.operators.gcp_sql_operator.CloudSqlBaseOperator method) _check_input() (airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator method) (airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator method) _check_mail_body() (airflow.contrib.hooks.imap_hook.ImapHook method) _check_name() (airflow.contrib.operators.azure_container_instances_operator.AzureContainerInstancesOperator static method) _check_ssl_file() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook static method) _check_success_task() (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator method) (airflow.contrib.operators.ecs_operator.ECSOperator method) _check_zone_operation_status() (airflow.contrib.hooks.gcp_compute_hook.GceHook static method) _cleanse_time_partitioning() (in module airflow.contrib.hooks.bigquery_hook) _client (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook attribute) (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook attribute) (airflow.contrib.hooks.gcp_speech_to_text_hook.GCPSpeechToTextHook attribute) (airflow.contrib.hooks.gcp_text_to_speech_hook.GCPTextToSpeechHook attribute) (airflow.contrib.hooks.gcp_translate_hook.CloudTranslateHook attribute) (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook attribute) _compare_column_families() (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableCreateOperator method) _comps (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.operators.BaseOperator attribute) _configure_csv_file() (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) _conn (airflow.contrib.hooks.gcp_cloud_build_hook.CloudBuildHook attribute) (airflow.contrib.hooks.gcp_compute_hook.GceHook attribute) (airflow.contrib.hooks.gcp_function_hook.GcfHook attribute) (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook attribute) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook attribute) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook attribute) (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook attribute) (airflow.contrib.hooks.gcp_video_intelligence_hook.CloudVideoIntelligenceHook attribute) (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook attribute) _convert_date_to_dict() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor static method) _convert_repo_url_to_dict() (airflow.contrib.operators.gcp_cloud_build_operator.BuildProcessor static method) _convert_storage_url_to_dict() (airflow.contrib.operators.gcp_cloud_build_operator.BuildProcessor static method) _convert_time_to_dict() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor static method) _convert_to_float_if_possible() (in module airflow.operators.check_operator) _copy_single_object() (airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator method) _correct_path() (airflow.contrib.hooks.imap_hook.ImapHook method) _create_body() (airflow.contrib.operators.gcp_transfer_operator.GoogleCloudStorageToGoogleCloudStorageTransferOperator method) (airflow.contrib.operators.gcp_transfer_operator.S3ToGoogleCloudStorageTransferOperator method) _create_file() (airflow.contrib.hooks.imap_hook.ImapHook method) _create_files() (airflow.contrib.hooks.imap_hook.ImapHook method) _create_hook() (airflow.contrib.sensors.ftp_sensor.FTPSensor method) (airflow.contrib.sensors.ftp_sensor.FTPSSensor method) _create_new_function() (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) _create_pod_id() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler static method) _Dataflow (class in airflow.contrib.hooks.gcp_dataflow_hook) _DataflowJob (class in airflow.contrib.hooks.gcp_dataflow_hook) _DataProcJob (class in airflow.contrib.hooks.gcp_dataproc_hook) _DataProcJobBuilder (class in airflow.contrib.hooks.gcp_dataproc_hook) _DataProcOperation (class in airflow.contrib.hooks.gcp_dataproc_hook) _datetime_to_label_safe_datestring() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler static method) _deep_string_coerce() (in module airflow.contrib.operators.databricks_operator) _DEFAULT_SCOPES (in module airflow.contrib.hooks.gcp_api_base_hook) _delete_top_row_and_compress() (airflow.operators.s3_to_hive_operator.S3ToHiveTransfer static method) _dict_to_proto() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook static method) _do_api_call() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) _do_render_template_fields() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) _do_skip_downstream_tasks() (airflow.sensors.base_sensor_operator.BaseSensorOperator method)

_download_sql_proxy_if_needed() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) _emit_duration_stats_for_finished_state() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) _escape() (in module airflow.contrib.hooks.bigquery_hook) _execute() (airflow.contrib.operators.oracle_to_oracle_transfer.OracleToOracleTransfer method) _execute_in_subprocess() (airflow.operators.python_operator.PythonVirtualenvOperator method) _execute_set_machine_type() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) _execute_sql_in_transaction() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook static method) _export_cmd() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) _extra (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) _extract_job() (airflow.contrib.hooks.gcp_dataflow_hook._Dataflow static method) _fernet (in module airflow.models.crypto) _fetch_mail_body() (airflow.contrib.hooks.imap_hook.ImapHook method) _find_valid_server() (airflow.hooks.hive_hooks.HiveMetastoreHook method) _flush_result_queue() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) _flush_task_queue() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) _flush_watcher_queue() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) _format_subscription() (in module airflow.contrib.hooks.gcp_pubsub_hook) _format_topic() (in module airflow.contrib.hooks.gcp_pubsub_hook) _full_location() (airflow.contrib.hooks.gcp_function_hook.GcfHook static method) _gcs_object_is_directory() (airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator static method) _generate_connection_uri() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) _generate_pip_install_cmd() (airflow.operators.python_operator.PythonVirtualenvOperator method) _generate_python_cmd() (airflow.operators.python_operator.PythonVirtualenvOperator static method) _generate_python_code() (airflow.operators.python_operator.PythonVirtualenvOperator method) _generate_temp_filename() (airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator static method) _generate_unique_path() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook static method) _generate_virtualenv_cmd() (airflow.operators.python_operator.PythonVirtualenvOperator method) _get_access_token() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook method) _get_api_key() (airflow.contrib.hooks.opsgenie_alert_hook.OpsgenieAlertHook method) _get_autogenerated_id() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook static method) _get_aws_credentials() (airflow.contrib.hooks.snowflake_hook.SnowflakeHook method) _get_bool() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook static method) _get_client() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook method) (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) (airflow.hooks.webhdfs_hook.WebHDFSHook method) _get_col_type_dict() (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) _get_concurrency_reached() (airflow.models.DAG method) (airflow.models.dag.DAG method) _get_conn_params() (airflow.contrib.hooks.snowflake_hook.SnowflakeHook method) _get_connection_from_env() (airflow.hooks.base_hook.BaseHook class method) _get_connections_from_db() (airflow.hooks.base_hook.BaseHook class method) _get_credential_parameters() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) _get_credentials() (airflow.contrib.hooks.aws_hook.AwsHook method) (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook method) _get_endpoint() (airflow.contrib.hooks.dingding_hook.DingdingHook method) _get_error_code() (airflow.contrib.sensors.ftp_sensor.FTPSensor method) _get_executor() (in module airflow.executors) _get_export_format_argument() (airflow.contrib.hooks.sqoop_hook.SqoopHook static method) _get_field() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook method) (airflow.contrib.hooks.grpc_hook.GrpcHook method) (airflow.contrib.operators.gcp_container_operator.GKEPodOperator method) _get_filtered_args() (airflow.contrib.operators.qubole_operator.QuboleOperator method) _get_graceful_decommission_timeout() (airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator static method) _get_init_action_timeout() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _get_instance_socket_name() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) _get_is_paused() (airflow.models.DAG method) (airflow.models.dag.DAG method) _get_job() (airflow.contrib.hooks.gcp_dataflow_hook._DataflowJob method) (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) _get_job_id_from_name() (airflow.contrib.hooks.gcp_dataflow_hook._DataflowJob method) _get_latest_execution_date() (airflow.models.DAG method) (airflow.models.dag.DAG method) _get_max_partition_from_part_specs() (airflow.hooks.hive_hooks.HiveMetastoreHook static method) _get_numeric_matches() (airflow.operators.check_operator.ValueCheckOperator method) _get_pretty_exception_message() (airflow.hooks.presto_hook.PrestoHook static method) _get_previous_ti() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) _get_project_id() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook method) _get_proxy_user() (airflow.hooks.hive_hooks.HiveCliHook method) _get_results() (airflow.hooks.hive_hooks.HiveServer2Hook method) _get_security_context_val() (airflow.contrib.executors.kubernetes_executor.KubeConfig method) _get_settings_version() (airflow.contrib.operators.gcp_sql_operator.CloudSqlBaseOperator static method) _get_spark_binary_path() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _get_sqlproxy_instance_specification() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) _get_string_matches() (airflow.operators.check_operator.ValueCheckOperator method) _get_token() (airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook method) _get_top_row_as_list() (airflow.operators.s3_to_hive_operator.S3ToHiveTransfer method) _get_webhook_endpoint() (airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook method) _handle_databricks_operator_execution() (in module airflow.contrib.operators.databricks_operator) _handle_not_found_mode() (airflow.contrib.hooks.imap_hook.ImapHook method) _handle_reschedule() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) _health_check_kube_watcher() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) _hooks (in module airflow.contrib.hooks) (in module airflow.hooks) _import_cmd() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) _inject_aws_credentials() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor method) _inject_project_id() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) _inject_secrets() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) _integrate_plugins() (in module airflow.executors) (in module airflow.hooks) (in module airflow.operators) (in module airflow.sensors) _is_escaping_current_directory() (airflow.contrib.hooks.imap_hook.ImapHook method) _is_os_64bit() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner static method) _is_present_and_empty() (airflow.contrib.operators.gcp_function_operator.ZipPathPreprocessor static method) _is_symlink() (airflow.contrib.hooks.imap_hook.ImapHook method) _kerberos_security_mode (in module airflow.hooks.webhdfs_hook) _label_safe_datestring_to_datetime() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler static method) _labels_to_key() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) _line() (airflow.contrib.hooks.gcp_dataflow_hook._Dataflow method) _list_mail_ids_desc() (airflow.contrib.hooks.imap_hook.ImapHook method) _log_last() (airflow.contrib.operators.azure_container_instances_operator.AzureContainerInstancesOperator method) _log_request_error() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) _make_intermediate_dirs() (in module airflow.contrib.operators.sftp_operator) _make_kube_watcher() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) _make_safe_label_value() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler static method) _make_safe_pod_id() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler static method) _match_headers() (airflow.operators.s3_to_hive_operator.S3ToHiveTransfer method) _monitor_logging() (airflow.contrib.operators.azure_container_instances_operator.AzureContainerInstancesOperator method) _normalize_mlengine_job_id() (in module airflow.contrib.operators.mlengine_operator) _num_tasks_per_fetch_process() (airflow.executors.celery_executor.CeleryExecutor method) _num_tasks_per_send_process() (airflow.executors.celery_executor.CeleryExecutor method) _operators (in module airflow.contrib.operators) (in module airflow.operators) _parse_gcs_url() (in module airflow.contrib.hooks.gcs_hook) _parse_host() (airflow.contrib.hooks.databricks_hook.DatabricksHook static method) _parse_s3_config() (in module airflow.contrib.hooks.aws_hook) _pass_op_args() (airflow.operators.python_operator.PythonVirtualenvOperator method) _password (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) _poll_with_exponential_delay() (in module airflow.contrib.hooks.gcp_mlengine_hook) _possibly_replace_template() (airflow.contrib.operators.gcp_compute_operator.GceInstanceGroupManagerUpdateTemplateOperator method) _prepare_cli_cmd() (airflow.hooks.hive_hooks.HiveCliHook method) _prepare_command() (airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method) (airflow.contrib.hooks.sqoop_hook.SqoopHook method) _prepare_hiveconf() (airflow.hooks.hive_hooks.HiveCliHook static method) _process_future() (airflow.executors.dask_executor.DaskExecutor method) _process_spark_status_log() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _process_spark_submit_log() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _query_cassandra() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator method) _quote() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook static method) _raise_error() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcOperation method) _raise_ex_different_names() (airflow.contrib.hooks.gcp_vision_hook.NameDeterminer method) _raise_ex_unable_to_determine_name() (airflow.contrib.hooks.gcp_vision_hook.NameDeterminer method) _read_result() (airflow.operators.python_operator.PythonVirtualenvOperator method) _reformat_date() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor method) _reformat_repo_source() (airflow.contrib.operators.gcp_cloud_build_operator.BuildProcessor method) _reformat_schedule() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor method) _reformat_source() (airflow.contrib.operators.gcp_cloud_build_operator.BuildProcessor method) _reformat_storage_source() (airflow.contrib.operators.gcp_cloud_build_operator.BuildProcessor method) _reformat_time() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor method) _render_nested_template_fields() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) _resolve_connection() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _resolve_jdbc_connection() (airflow.contrib.hooks.spark_jdbc_hook.SparkJDBCHook method) _resolve_should_track_driver_status() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _restrict_aws_credentials() (airflow.contrib.operators.gcp_transfer_operator.TransferJobValidator method) _restrict_empty_body() (airflow.contrib.operators.gcp_transfer_operator.TransferJobValidator method) _retrieve_mails_attachments_by_name() (airflow.contrib.hooks.imap_hook.ImapHook method) _retryable_error() (in module airflow.contrib.hooks.databricks_hook) _run() (airflow.contrib.executors.kubernetes_executor.KubernetesJobWatcher method) _run_raw_task() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) _sensors (in module airflow.sensors) _serialize_cell() (airflow.hooks.dbapi_hook.DbApiHook static method) (airflow.hooks.mysql_hook.MySqlHook static method) (airflow.hooks.postgres_hook.PostgresHook static method) _set_airflow_version_label() (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) _set_context() (airflow.executors.LoggingMixin method) _set_env_from_extras() (airflow.contrib.operators.gcp_container_operator.GKEPodOperator method) _set_relatives() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) _set_resources() (airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator method) _set_variables() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook static method) _split_tablename() (in module airflow.contrib.hooks.bigquery_hook) _start_dataflow() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method) _start_driver_status_tracking() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) _start_template_dataflow() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method) _state (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) _stringify() (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator static method) _strip_sql() (airflow.hooks.presto_hook.PrestoHook static method) _strip_unsafe_kubernetes_special_chars() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler static method) _test_cycle_helper() (airflow.models.DAG method) (airflow.models.dag.DAG method) _to_float() (airflow.operators.check_operator.ValueCheckOperator method) _to_timestamp() (airflow.contrib.hooks.salesforce_hook.SalesforceHook class method) _TokenAuth (class in airflow.contrib.hooks.databricks_hook) _try_number (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) _types (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) _update_function() (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) _upload_file_temp() (airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator method) _upload_source_code() (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) _upload_to_gcs() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator method) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) _val (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) _validate() (airflow.contrib.executors.kubernetes_executor.KubeConfig method) _validate_all_body_fields() (airflow.contrib.operators.gcp_compute_operator.GceInstanceTemplateCopyOperator method) (airflow.contrib.operators.gcp_compute_operator.GceSetMachineTypeOperator method) (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) _validate_available_memory_in_mb() (in module airflow.contrib.operators.gcp_function_operator) _validate_body_fields() (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceExportOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceImportOperator method) _validate_input_values() (airflow.sensors.base_sensor_operator.BaseSensorOperator method) _validate_inputs() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) (airflow.contrib.operators.gcp_bigtable_operator.BigtableValidationMixin method) (airflow.contrib.operators.gcp_cloud_build_operator.CloudBuildCreateBuildOperator method) (airflow.contrib.operators.gcp_compute_operator.GceBaseOperator method) (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeleteOperator method) (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeleteOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeployOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseQueryOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseUpdateOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeleteOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeployOperator method) (airflow.contrib.operators.gcp_speech_to_text_operator.GcpSpeechToTextRecognizeSpeechOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlBaseOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseDeleteOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceExportOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceImportOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstancePatchOperator method) (airflow.contrib.operators.gcp_text_to_speech_operator.GcpTextToSpeechSynthesizeOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobCreateOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobDeleteOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobUpdateOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationCancelOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationGetOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationPauseOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationResumeOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationsListOperator method) _validate_max_instances() (in module airflow.contrib.operators.gcp_function_operator) _validate_value() (in module airflow.contrib.hooks.bigquery_hook) _verify_archive_url_and_zip_path() (airflow.contrib.operators.gcp_function_operator.ZipPathPreprocessor method) _verify_data_source() (airflow.contrib.operators.gcp_transfer_operator.TransferJobValidator method) _verify_source() (airflow.contrib.operators.gcp_cloud_build_operator.BuildProcessor method) _verify_upload_url_and_no_zip_path() (airflow.contrib.operators.gcp_function_operator.ZipPathPreprocessor method) _verify_upload_url_and_zip_path() (airflow.contrib.operators.gcp_function_operator.ZipPathPreprocessor method) _wait_for_job_done() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) _wait_for_operation_to_complete() (airflow.contrib.hooks.gcp_cloud_build_hook.CloudBuildHook method) (airflow.contrib.hooks.gcp_compute_hook.GceHook method) (airflow.contrib.hooks.gcp_function_hook.GcfHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) _wait_for_task_ended() (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator method) (airflow.contrib.operators.ecs_operator.ECSOperator method) _write_args() (airflow.operators.python_operator.PythonVirtualenvOperator method) _write_local_data_files() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator method) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) _write_local_schema_file() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator method) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) _write_script() (airflow.operators.python_operator.PythonVirtualenvOperator method) _write_string_args() (airflow.operators.python_operator.PythonVirtualenvOperator method) _write_temp_file() (airflow.contrib.operators.oracle_to_azure_data_lake_transfer.OracleToAzureDataLakeTransfer method)

A

ABORTED (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferOperationStatus attribute) access_control (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) ACCESS_KEY_ID (in module airflow.contrib.hooks.gcp_transfer_hook) acknowledge() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) add_archive_uris() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_args() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_file_uris() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_jar_file_uris() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_labels() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_only_new() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) add_product_to_product_set() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) add_python_file_uris() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_query() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_query_uri() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) add_task() (airflow.models.DAG method) (airflow.models.dag.DAG method) add_tasks() (airflow.models.DAG method) (airflow.models.dag.DAG method) add_variables() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) AdlsToGoogleCloudStorageOperator (class in airflow.contrib.operators.adls_to_gcs) aggregate() (airflow.contrib.hooks.mongo_hook.MongoHook method) airflow.contrib.executors (module) airflow.contrib.executors.kubernetes_executor (module) airflow.contrib.executors.mesos_executor (module) airflow.contrib.hooks (module) airflow.contrib.hooks.aws_athena_hook (module) airflow.contrib.hooks.aws_dynamodb_hook (module) airflow.contrib.hooks.aws_firehose_hook (module) airflow.contrib.hooks.aws_glue_catalog_hook (module) airflow.contrib.hooks.aws_hook (module) airflow.contrib.hooks.aws_lambda_hook (module) airflow.contrib.hooks.aws_logs_hook (module) airflow.contrib.hooks.aws_sns_hook (module) airflow.contrib.hooks.aws_sqs_hook (module) airflow.contrib.hooks.azure_container_instance_hook (module) airflow.contrib.hooks.azure_container_registry_hook (module) airflow.contrib.hooks.azure_container_volume_hook (module) airflow.contrib.hooks.azure_cosmos_hook (module) airflow.contrib.hooks.azure_data_lake_hook (module) airflow.contrib.hooks.azure_fileshare_hook (module) airflow.contrib.hooks.bigquery_hook (module) airflow.contrib.hooks.cassandra_hook (module) airflow.contrib.hooks.cloudant_hook (module) airflow.contrib.hooks.databricks_hook (module) airflow.contrib.hooks.datadog_hook (module) airflow.contrib.hooks.datastore_hook (module) airflow.contrib.hooks.dingding_hook (module) airflow.contrib.hooks.discord_webhook_hook (module) airflow.contrib.hooks.emr_hook (module) airflow.contrib.hooks.fs_hook (module) airflow.contrib.hooks.ftp_hook (module) airflow.contrib.hooks.gcp_api_base_hook (module) airflow.contrib.hooks.gcp_bigtable_hook (module) airflow.contrib.hooks.gcp_cloud_build_hook (module) airflow.contrib.hooks.gcp_compute_hook (module) airflow.contrib.hooks.gcp_container_hook (module) airflow.contrib.hooks.gcp_dataflow_hook (module) airflow.contrib.hooks.gcp_dataproc_hook (module) airflow.contrib.hooks.gcp_dlp_hook (module) airflow.contrib.hooks.gcp_function_hook (module) airflow.contrib.hooks.gcp_kms_hook (module) airflow.contrib.hooks.gcp_mlengine_hook (module) airflow.contrib.hooks.gcp_natural_language_hook (module) airflow.contrib.hooks.gcp_pubsub_hook (module) airflow.contrib.hooks.gcp_spanner_hook (module) airflow.contrib.hooks.gcp_speech_to_text_hook (module) airflow.contrib.hooks.gcp_sql_hook (module) airflow.contrib.hooks.gcp_text_to_speech_hook (module) airflow.contrib.hooks.gcp_transfer_hook (module) airflow.contrib.hooks.gcp_translate_hook (module) airflow.contrib.hooks.gcp_video_intelligence_hook (module) airflow.contrib.hooks.gcp_vision_hook (module) airflow.contrib.hooks.gcs_hook (module) airflow.contrib.hooks.grpc_hook (module) airflow.contrib.hooks.imap_hook (module) airflow.contrib.hooks.jenkins_hook (module) airflow.contrib.hooks.jira_hook (module) airflow.contrib.hooks.mongo_hook (module) airflow.contrib.hooks.openfaas_hook (module) airflow.contrib.hooks.opsgenie_alert_hook (module) airflow.contrib.hooks.pinot_hook (module) airflow.contrib.hooks.qubole_check_hook (module) airflow.contrib.hooks.qubole_hook (module) airflow.contrib.hooks.redis_hook (module) airflow.contrib.hooks.redshift_hook (module) airflow.contrib.hooks.sagemaker_hook (module) airflow.contrib.hooks.salesforce_hook (module) airflow.contrib.hooks.segment_hook (module) airflow.contrib.hooks.sftp_hook (module) airflow.contrib.hooks.slack_webhook_hook (module) airflow.contrib.hooks.snowflake_hook (module) airflow.contrib.hooks.spark_jdbc_hook (module) airflow.contrib.hooks.spark_jdbc_script (module) airflow.contrib.hooks.spark_sql_hook (module) airflow.contrib.hooks.spark_submit_hook (module) airflow.contrib.hooks.sqoop_hook (module) airflow.contrib.hooks.ssh_hook (module) airflow.contrib.hooks.vertica_hook (module) airflow.contrib.hooks.wasb_hook (module) airflow.contrib.hooks.winrm_hook (module) airflow.contrib.operators (module) airflow.contrib.operators.adls_list_operator (module) airflow.contrib.operators.adls_to_gcs (module) airflow.contrib.operators.aws_athena_operator (module) airflow.contrib.operators.aws_sqs_publish_operator (module) airflow.contrib.operators.awsbatch_operator (module) airflow.contrib.operators.azure_container_instances_operator (module) airflow.contrib.operators.azure_cosmos_operator (module) airflow.contrib.operators.bigquery_check_operator (module) airflow.contrib.operators.bigquery_get_data (module) airflow.contrib.operators.bigquery_operator (module) airflow.contrib.operators.bigquery_table_delete_operator (module) airflow.contrib.operators.bigquery_to_bigquery (module) airflow.contrib.operators.bigquery_to_gcs (module) airflow.contrib.operators.cassandra_to_gcs (module) airflow.contrib.operators.databricks_operator (module) airflow.contrib.operators.dataflow_operator (module) airflow.contrib.operators.dataproc_operator (module) airflow.contrib.operators.datastore_export_operator (module) airflow.contrib.operators.datastore_import_operator (module) airflow.contrib.operators.dingding_operator (module) airflow.contrib.operators.discord_webhook_operator (module) airflow.contrib.operators.druid_operator (module) airflow.contrib.operators.ecs_operator (module) airflow.contrib.operators.emr_add_steps_operator (module) airflow.contrib.operators.emr_create_job_flow_operator (module) airflow.contrib.operators.emr_terminate_job_flow_operator (module) airflow.contrib.operators.file_to_gcs (module) airflow.contrib.operators.file_to_wasb (module) airflow.contrib.operators.gcp_bigtable_operator (module) airflow.contrib.operators.gcp_cloud_build_operator (module) airflow.contrib.operators.gcp_compute_operator (module) airflow.contrib.operators.gcp_container_operator (module) airflow.contrib.operators.gcp_dlp_operator (module) airflow.contrib.operators.gcp_function_operator (module) airflow.contrib.operators.gcp_natural_language_operator (module) airflow.contrib.operators.gcp_spanner_operator (module) airflow.contrib.operators.gcp_speech_to_text_operator (module) airflow.contrib.operators.gcp_sql_operator (module) airflow.contrib.operators.gcp_text_to_speech_operator (module) airflow.contrib.operators.gcp_transfer_operator (module) airflow.contrib.operators.gcp_translate_operator (module) airflow.contrib.operators.gcp_translate_speech_operator (module) airflow.contrib.operators.gcp_video_intelligence_operator (module) airflow.contrib.operators.gcp_vision_operator (module) airflow.contrib.operators.gcs_acl_operator (module) airflow.contrib.operators.gcs_delete_operator (module) airflow.contrib.operators.gcs_download_operator (module) airflow.contrib.operators.gcs_list_operator (module) airflow.contrib.operators.gcs_operator (module) airflow.contrib.operators.gcs_to_bq (module) airflow.contrib.operators.gcs_to_gcs (module) airflow.contrib.operators.gcs_to_s3 (module) airflow.contrib.operators.hipchat_operator (module) airflow.contrib.operators.hive_to_dynamodb (module) airflow.contrib.operators.imap_attachment_to_s3_operator (module) airflow.contrib.operators.jenkins_job_trigger_operator (module) airflow.contrib.operators.jira_operator (module) airflow.contrib.operators.kubernetes_pod_operator (module) airflow.contrib.operators.mlengine_operator (module) airflow.contrib.operators.mongo_to_s3 (module) airflow.contrib.operators.mssql_to_gcs (module) airflow.contrib.operators.mysql_to_gcs (module) airflow.contrib.operators.opsgenie_alert_operator (module) airflow.contrib.operators.oracle_to_azure_data_lake_transfer (module) airflow.contrib.operators.oracle_to_oracle_transfer (module) airflow.contrib.operators.postgres_to_gcs_operator (module) airflow.contrib.operators.pubsub_operator (module) airflow.contrib.operators.qubole_check_operator (module) airflow.contrib.operators.qubole_operator (module) airflow.contrib.operators.redis_publish_operator (module) airflow.contrib.operators.s3_copy_object_operator (module) airflow.contrib.operators.s3_delete_objects_operator (module) airflow.contrib.operators.s3_list_operator (module) airflow.contrib.operators.s3_to_gcs_operator (module) airflow.contrib.operators.s3_to_sftp_operator (module) airflow.contrib.operators.sagemaker_base_operator (module) airflow.contrib.operators.sagemaker_endpoint_config_operator (module) airflow.contrib.operators.sagemaker_endpoint_operator (module) airflow.contrib.operators.sagemaker_model_operator (module) airflow.contrib.operators.sagemaker_training_operator (module) airflow.contrib.operators.sagemaker_transform_operator (module) airflow.contrib.operators.sagemaker_tuning_operator (module) airflow.contrib.operators.segment_track_event_operator (module) airflow.contrib.operators.sftp_operator (module) airflow.contrib.operators.sftp_to_s3_operator (module) airflow.contrib.operators.slack_webhook_operator (module) airflow.contrib.operators.snowflake_operator (module) airflow.contrib.operators.sns_publish_operator (module) airflow.contrib.operators.spark_jdbc_operator (module) airflow.contrib.operators.spark_sql_operator (module) airflow.contrib.operators.spark_submit_operator (module) airflow.contrib.operators.sql_to_gcs (module) airflow.contrib.operators.sqoop_operator (module) airflow.contrib.operators.ssh_operator (module)

airflow.contrib.operators.vertica_operator (module) airflow.contrib.operators.vertica_to_hive (module) airflow.contrib.operators.vertica_to_mysql (module) airflow.contrib.operators.wasb_delete_blob_operator (module) airflow.contrib.operators.winrm_operator (module) airflow.contrib.sensors (module) airflow.contrib.sensors.aws_athena_sensor (module) airflow.contrib.sensors.aws_glue_catalog_partition_sensor (module) airflow.contrib.sensors.aws_redshift_cluster_sensor (module) airflow.contrib.sensors.aws_sqs_sensor (module) airflow.contrib.sensors.azure_cosmos_sensor (module) airflow.contrib.sensors.bash_sensor (module) airflow.contrib.sensors.bigquery_sensor (module) airflow.contrib.sensors.cassandra_record_sensor (module) airflow.contrib.sensors.cassandra_table_sensor (module) airflow.contrib.sensors.datadog_sensor (module) airflow.contrib.sensors.emr_base_sensor (module) airflow.contrib.sensors.emr_job_flow_sensor (module) airflow.contrib.sensors.emr_step_sensor (module) airflow.contrib.sensors.file_sensor (module) airflow.contrib.sensors.ftp_sensor (module) airflow.contrib.sensors.gcp_transfer_sensor (module) airflow.contrib.sensors.gcs_sensor (module) airflow.contrib.sensors.hdfs_sensor (module) airflow.contrib.sensors.imap_attachment_sensor (module) airflow.contrib.sensors.jira_sensor (module) airflow.contrib.sensors.mongo_sensor (module) airflow.contrib.sensors.pubsub_sensor (module) airflow.contrib.sensors.python_sensor (module) airflow.contrib.sensors.qubole_sensor (module) airflow.contrib.sensors.redis_key_sensor (module) airflow.contrib.sensors.redis_pub_sub_sensor (module) airflow.contrib.sensors.sagemaker_base_sensor (module) airflow.contrib.sensors.sagemaker_endpoint_sensor (module) airflow.contrib.sensors.sagemaker_training_sensor (module) airflow.contrib.sensors.sagemaker_transform_sensor (module) airflow.contrib.sensors.sagemaker_tuning_sensor (module) airflow.contrib.sensors.sftp_sensor (module) airflow.contrib.sensors.wasb_sensor (module) airflow.contrib.sensors.weekday_sensor (module) airflow.executors (module) airflow.executors.base_executor (module) airflow.executors.celery_executor (module) airflow.executors.dask_executor (module) airflow.executors.local_executor (module) airflow.executors.sequential_executor (module) airflow.hooks (module) airflow.hooks.base_hook (module) airflow.hooks.dbapi_hook (module) airflow.hooks.docker_hook (module) airflow.hooks.druid_hook (module) airflow.hooks.hdfs_hook (module) airflow.hooks.hive_hooks (module) airflow.hooks.http_hook (module) airflow.hooks.jdbc_hook (module) airflow.hooks.mssql_hook (module) airflow.hooks.mysql_hook (module) airflow.hooks.oracle_hook (module) airflow.hooks.pig_hook (module) airflow.hooks.postgres_hook (module) airflow.hooks.presto_hook (module) airflow.hooks.S3_hook (module) airflow.hooks.samba_hook (module) airflow.hooks.slack_hook (module) airflow.hooks.sqlite_hook (module) airflow.hooks.webhdfs_hook (module) airflow.hooks.zendesk_hook (module) airflow.macros (module) airflow.models (module) airflow.models.base (module) airflow.models.baseoperator (module) airflow.models.chart (module) airflow.models.connection (module) airflow.models.crypto (module) airflow.models.dag (module) airflow.models.dagbag (module) airflow.models.dagpickle (module) airflow.models.dagrun (module) airflow.models.errors (module) airflow.models.knownevent (module) airflow.models.kubernetes (module) airflow.models.log (module) airflow.models.pool (module) airflow.models.skipmixin (module) airflow.models.slamiss (module) airflow.models.taskfail (module) airflow.models.taskinstance (module) airflow.models.taskreschedule (module) airflow.models.user (module) airflow.models.variable (module) airflow.models.xcom (module) airflow.operators (module) airflow.operators.bash_operator (module) airflow.operators.branch_operator (module) airflow.operators.check_operator (module) airflow.operators.dagrun_operator (module) airflow.operators.docker_operator (module) airflow.operators.druid_check_operator (module) airflow.operators.dummy_operator (module) airflow.operators.email_operator (module) airflow.operators.generic_transfer (module) airflow.operators.hive_operator (module) airflow.operators.hive_stats_operator (module) airflow.operators.hive_to_druid (module) airflow.operators.hive_to_mysql (module) airflow.operators.hive_to_samba_operator (module) airflow.operators.http_operator (module) airflow.operators.jdbc_operator (module) airflow.operators.latest_only_operator (module) airflow.operators.mssql_operator (module) airflow.operators.mssql_to_hive (module) airflow.operators.mysql_operator (module) airflow.operators.mysql_to_hive (module) airflow.operators.oracle_operator (module) airflow.operators.papermill_operator (module) airflow.operators.pig_operator (module) airflow.operators.postgres_operator (module) airflow.operators.presto_check_operator (module) airflow.operators.presto_to_mysql (module) airflow.operators.python_operator (module) airflow.operators.redshift_to_s3_operator (module) airflow.operators.s3_file_transform_operator (module) airflow.operators.s3_to_hive_operator (module) airflow.operators.s3_to_redshift_operator (module) airflow.operators.sensors (module) airflow.operators.slack_operator (module) airflow.operators.sqlite_operator (module) airflow.operators.subdag_operator (module) airflow.sensors (module) airflow.sensors.base_sensor_operator (module) airflow.sensors.external_task_sensor (module) airflow.sensors.hdfs_sensor (module) airflow.sensors.hive_partition_sensor (module) airflow.sensors.http_sensor (module) airflow.sensors.metastore_partition_sensor (module) airflow.sensors.named_hive_partition_sensor (module) airflow.sensors.s3_key_sensor (module) airflow.sensors.s3_prefix_sensor (module) airflow.sensors.sql_sensor (module) airflow.sensors.time_delta_sensor (module) airflow.sensors.time_sensor (module) airflow.sensors.web_hdfs_sensor (module) airflow_importer (in module airflow.contrib.hooks) (in module airflow.contrib.operators) (in module airflow.hooks) (in module airflow.operators) (in module airflow.sensors) AirflowException AirflowKubernetesScheduler (class in airflow.contrib.executors.kubernetes_executor) AirflowMesosScheduler (class in airflow.contrib.executors.mesos_executor) AirflowWebHDFSHookException allocate_ids() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) ALREADY_EXISTING_IN_SINK (in module airflow.contrib.hooks.gcp_transfer_hook) analyze_entities() (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook method) analyze_entity_sentiment() (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook method) analyze_sentiment() (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook method) analyze_syntax() (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook method) annotate_image() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) annotate_text() (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook method) annotate_video() (airflow.contrib.hooks.gcp_video_intelligence_hook.CloudVideoIntelligenceHook method) annotator_client() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) app (in module airflow.executors.celery_executor) are_dependencies_met() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) are_dependents_done() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) argmin() (in module airflow.contrib.hooks.sagemaker_hook) arn (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator attribute) (airflow.contrib.operators.ecs_operator.ECSOperator attribute) arraysize (airflow.contrib.hooks.bigquery_hook.BigQueryCursor attribute) as_dict() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutorConfig method) AthenaSensor (class in airflow.contrib.sensors.aws_athena_sensor) attributes (airflow.operators.papermill_operator.NoteBook attribute) AWS_ACCESS_KEY (in module airflow.contrib.hooks.gcp_transfer_hook) AWS_S3_DATA_SOURCE (in module airflow.contrib.hooks.gcp_transfer_hook) 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) 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) (in module airflow.contrib.operators.gcp_transfer_operator) AwsLambdaHook (class in airflow.contrib.hooks.aws_lambda_hook) AwsLogsHook (class in airflow.contrib.hooks.aws_logs_hook) AwsRedshiftClusterSensor (class in airflow.contrib.sensors.aws_redshift_cluster_sensor) AwsSnsHook (class in airflow.contrib.hooks.aws_sns_hook) AzureContainerInstanceHook (class in airflow.contrib.hooks.azure_container_instance_hook) AzureContainerInstancesOperator (class in airflow.contrib.operators.azure_container_instances_operator) AzureContainerRegistryHook (class in airflow.contrib.hooks.azure_container_registry_hook) AzureContainerVolumeHook (class in airflow.contrib.hooks.azure_container_volume_hook) AzureCosmosDBHook (class in airflow.contrib.hooks.azure_cosmos_hook) AzureCosmosDocumentSensor (class in airflow.contrib.sensors.azure_cosmos_sensor) AzureCosmosInsertDocumentOperator (class in airflow.contrib.operators.azure_cosmos_operator) AzureDataLakeHook (class in airflow.contrib.hooks.azure_data_lake_hook) AzureDataLakeStorageListOperator (class in airflow.contrib.operators.adls_list_operator) AzureFileShareHook (class in airflow.contrib.hooks.azure_fileshare_hook)

B

bag_dag() (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) Base (in module airflow.models) (in module airflow.models.base) BaseBranchOperator (class in airflow.operators.branch_operator) BaseExecutor (class in airflow.executors) (class in airflow.executors.base_executor) BaseHook (class in airflow.hooks.base_hook) BaseOperator (class in airflow.models) (class in airflow.models.baseoperator) (class in airflow.operators) BaseOperatorLink (class in airflow.models.baseoperator) BaseSensorOperator (class in airflow.operators.sensors) (class in airflow.sensors.base_sensor_operator) BaseSQLToGoogleCloudStorageOperator (class in airflow.contrib.operators.sql_to_gcs) BashOperator (class in airflow.operators.bash_operator) BashSensor (class in airflow.contrib.sensors.bash_sensor) batch_annotate_images() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) begin_transaction() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) BigQueryBaseCursor (class in airflow.contrib.hooks.bigquery_hook) BigQueryCheckOperator (class in airflow.contrib.operators.bigquery_check_operator) BigQueryConnection (class in airflow.contrib.hooks.bigquery_hook) BigQueryConsoleLink (class in airflow.contrib.operators.bigquery_operator) BigQueryCreateEmptyDatasetOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryCreateEmptyTableOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryCreateExternalTableOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryCursor (class in airflow.contrib.hooks.bigquery_hook) BigQueryDeleteDatasetOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryGetDataOperator (class in airflow.contrib.operators.bigquery_get_data) BigQueryGetDatasetOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryHook (class in airflow.contrib.hooks.bigquery_hook)

BigQueryIntervalCheckOperator (class in airflow.contrib.operators.bigquery_check_operator) BigQueryOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryPandasConnector (class in airflow.contrib.hooks.bigquery_hook) BigQueryPatchDatasetOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryTableDeleteOperator (class in airflow.contrib.operators.bigquery_table_delete_operator) BigQueryTableSensor (class in airflow.contrib.sensors.bigquery_sensor) BigQueryToBigQueryOperator (class in airflow.contrib.operators.bigquery_to_bigquery) BigQueryToCloudStorageOperator (class in airflow.contrib.operators.bigquery_to_gcs) BigQueryUpdateDatasetOperator (class in airflow.contrib.operators.bigquery_operator) BigQueryValueCheckOperator (class in airflow.contrib.operators.bigquery_check_operator) BigtableClusterUpdateOperator (class in airflow.contrib.operators.gcp_bigtable_operator) BigtableHook (class in airflow.contrib.hooks.gcp_bigtable_hook) BigtableInstanceCreateOperator (class in airflow.contrib.operators.gcp_bigtable_operator) BigtableInstanceDeleteOperator (class in airflow.contrib.operators.gcp_bigtable_operator) BigtableTableCreateOperator (class in airflow.contrib.operators.gcp_bigtable_operator) BigtableTableDeleteOperator (class in airflow.contrib.operators.gcp_bigtable_operator) BigtableTableWaitForReplicationSensor (class in airflow.contrib.operators.gcp_bigtable_operator) BigtableValidationMixin (class in airflow.contrib.operators.gcp_bigtable_operator) BODY (in module airflow.contrib.hooks.gcp_transfer_hook) BranchPythonOperator (class in airflow.operators.python_operator) BUCKET_NAME (in module airflow.contrib.hooks.gcp_transfer_hook) build() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) build_command_args() (in module airflow.contrib.hooks.qubole_hook) build_job() (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method) BuildProcessor (class in airflow.contrib.operators.gcp_cloud_build_operator) bulk_dump() (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.mysql_hook.MySqlHook method) (airflow.hooks.postgres_hook.PostgresHook method) bulk_insert_rows() (airflow.hooks.oracle_hook.OracleHook 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.slack_hook.SlackHook method) (airflow.hooks.zendesk_hook.ZendeskHook method) cancel() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) cancel_dlp_job() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) cancel_query() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) cancel_run() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) CANCEL_RUN_ENDPOINT (in module airflow.contrib.hooks.databricks_hook) cancel_transfer_operation() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook 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) catch_http_exception() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook static method) celery_configuration (in module airflow.executors.celery_executor) CELERY_FETCH_ERR_MSG_HEADER (in module airflow.executors.celery_executor) CELERY_SEND_ERR_MSG_HEADER (in module airflow.executors.celery_executor) CeleryExecutor (airflow.executors.Executors attribute) (class in airflow.executors.celery_executor) change_state() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) Chart (class in airflow.models) (class in airflow.models.chart) chart_type (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) check_for_blob() (airflow.contrib.hooks.wasb_hook.WasbHook method) check_for_bucket() (airflow.hooks.S3_hook.S3Hook method) check_for_directory() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) check_for_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method) (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) check_for_key() (airflow.hooks.S3_hook.S3Hook method) 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_path() (airflow.hooks.webhdfs_hook.WebHDFSHook method) check_for_prefix() (airflow.contrib.hooks.wasb_hook.WasbHook method) (airflow.hooks.S3_hook.S3Hook method) check_for_wildcard_key() (airflow.hooks.S3_hook.S3Hook method) 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) check_status() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) check_training_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) check_training_status_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) check_tuning_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) CheckOperator (class in airflow.operators.check_operator) checkpoint_kube_worker_uuid() (airflow.models.kubernetes.KubeWorkerIdentifier static method) (airflow.models.KubeWorkerIdentifier static method) checkpoint_resource_version() (airflow.models.KubeResourceVersion static method) (airflow.models.kubernetes.KubeResourceVersion static method) choose_branch() (airflow.operators.branch_operator.BaseBranchOperator method) classify_text() (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook method) cleanup_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) clear() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) clear_dags() (airflow.models.DAG class method) (airflow.models.dag.DAG class method) clear_not_launched_queued_tasks() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) clear_task_instances() (in module airflow.models) (in module airflow.models.taskinstance) clear_xcom_data() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) cli() (airflow.models.DAG method) (airflow.models.dag.DAG method) client (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator attribute) (airflow.contrib.operators.ecs_operator.ECSOperator attribute) close() (airflow.contrib.hooks.bigquery_hook.BigQueryConnection method) (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) close_conn() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) closest_ds_partition() (in module airflow.macros.hive) CLOUD_FUNCTION_VALIDATION (in module airflow.contrib.operators.gcp_function_operator) CLOUD_SQL_CREATE_VALIDATION (in module airflow.contrib.operators.gcp_sql_operator) CLOUD_SQL_DATABASE_CREATE_VALIDATION (in module airflow.contrib.operators.gcp_sql_operator) CLOUD_SQL_DATABASE_PATCH_VALIDATION (in module airflow.contrib.operators.gcp_sql_operator) CLOUD_SQL_EXPORT_VALIDATION (in module airflow.contrib.operators.gcp_sql_operator) CLOUD_SQL_IMPORT_VALIDATION (in module airflow.contrib.operators.gcp_sql_operator) CLOUD_SQL_PROXY_DOWNLOAD_URL (in module airflow.contrib.hooks.gcp_sql_hook) CLOUD_SQL_PROXY_VERSION_DOWNLOAD_URL (in module airflow.contrib.hooks.gcp_sql_hook) CLOUD_SQL_VALID_DATABASE_TYPES (in module airflow.contrib.hooks.gcp_sql_hook) CloudantHook (class in airflow.contrib.hooks.cloudant_hook) CloudBuildCreateBuildOperator (class in airflow.contrib.operators.gcp_cloud_build_operator) CloudBuildHook (class in airflow.contrib.hooks.gcp_cloud_build_hook) CloudDLPCancelDLPJobOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPCreateDeidentifyTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPCreateDLPJobOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPCreateInspectTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPCreateJobTriggerOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPCreateStoredInfoTypeOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPDeidentifyContentOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPDeleteDeidentifyTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPDeleteDlpJobOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPDeleteInspectTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPDeleteJobTriggerOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPDeleteStoredInfoTypeOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPGetDeidentifyTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPGetDlpJobOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPGetInspectTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPGetJobTripperOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPGetStoredInfoTypeOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPHook (class in airflow.contrib.hooks.gcp_dlp_hook) CloudDLPInspectContentOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPListDeidentifyTemplatesOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPListDlpJobsOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPListInfoTypesOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPListInspectTemplatesOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPListJobTriggersOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPListStoredInfoTypesOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPRedactImageOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPReidentifyContentOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPUpdateDeidentifyTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPUpdateInspectTemplateOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPUpdateJobTriggerOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudDLPUpdateStoredInfoTypeOperator (class in airflow.contrib.operators.gcp_dlp_operator) CloudLanguageAnalyzeEntitiesOperator (class in airflow.contrib.operators.gcp_natural_language_operator) CloudLanguageAnalyzeEntitySentimentOperator (class in airflow.contrib.operators.gcp_natural_language_operator) CloudLanguageAnalyzeSentimentOperator (class in airflow.contrib.operators.gcp_natural_language_operator) CloudLanguageClassifyTextOperator (class in airflow.contrib.operators.gcp_natural_language_operator) CloudNaturalLanguageHook (class in airflow.contrib.hooks.gcp_natural_language_hook) CloudSpannerHook (class in airflow.contrib.hooks.gcp_spanner_hook) CloudSpannerInstanceDatabaseDeleteOperator (class in airflow.contrib.operators.gcp_spanner_operator) CloudSpannerInstanceDatabaseDeployOperator (class in airflow.contrib.operators.gcp_spanner_operator) CloudSpannerInstanceDatabaseQueryOperator (class in airflow.contrib.operators.gcp_spanner_operator) CloudSpannerInstanceDatabaseUpdateOperator (class in airflow.contrib.operators.gcp_spanner_operator) CloudSpannerInstanceDeleteOperator (class in airflow.contrib.operators.gcp_spanner_operator) CloudSpannerInstanceDeployOperator (class in airflow.contrib.operators.gcp_spanner_operator) CloudSqlBaseOperator (class in airflow.contrib.operators.gcp_sql_operator) 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) CloudSqlOperationStatus (class in airflow.contrib.hooks.gcp_sql_hook) CloudSqlProxyRunner (class in airflow.contrib.hooks.gcp_sql_hook) CloudSqlQueryOperator (class in airflow.contrib.operators.gcp_sql_operator) CloudTranslateHook (class in airflow.contrib.hooks.gcp_translate_hook) CloudTranslateTextOperator (class in airflow.contrib.operators.gcp_translate_operator) CloudVideoIntelligenceDetectVideoExplicitContentOperator (class in airflow.contrib.operators.gcp_video_intelligence_operator) CloudVideoIntelligenceDetectVideoLabelsOperator (class in airflow.contrib.operators.gcp_video_intelligence_operator) CloudVideoIntelligenceDetectVideoShotsOperator (class in airflow.contrib.operators.gcp_video_intelligence_operator)

CloudVideoIntelligenceHook (class in airflow.contrib.hooks.gcp_video_intelligence_hook) CloudVisionAddProductToProductSetOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionAnnotateImageOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionDetectDocumentTextOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionDetectImageLabelsOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionDetectImageSafeSearchOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionDetectTextOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionHook (class in airflow.contrib.hooks.gcp_vision_hook) CloudVisionProductCreateOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionProductDeleteOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionProductGetOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionProductSetCreateOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionProductSetDeleteOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionProductSetGetOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionProductSetUpdateOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionProductUpdateOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionReferenceImageCreateOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionRemoveProductFromProductSetOperator (class in airflow.contrib.operators.gcp_vision_operator) cluster_status() (airflow.contrib.hooks.redshift_hook.RedshiftHook method) cmd_mask_password() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) COL_DELIM (in module airflow.contrib.hooks.qubole_check_hook) collect_dags() (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) command() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) command_as_list() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) COMMAND_CLASSES (in module airflow.contrib.hooks.qubole_hook) commit() (airflow.contrib.hooks.bigquery_hook.BigQueryConnection method) (airflow.contrib.hooks.datastore_hook.DatastoreHook method) COMPLETE (airflow.contrib.hooks.sagemaker_hook.LogState attribute) compose() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) concurrency (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) concurrency_reached (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) conf (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (in module airflow.executors) configure_s3_resources() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) CONN_ENV_PREFIX (in module airflow.hooks.base_hook) conn_id (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) conn_name_attr (airflow.contrib.hooks.bigquery_hook.BigQueryHook attribute) (airflow.contrib.hooks.pinot_hook.PinotDbApiHook attribute) (airflow.contrib.hooks.snowflake_hook.SnowflakeHook attribute) (airflow.contrib.hooks.vertica_hook.VerticaHook attribute) (airflow.hooks.dbapi_hook.DbApiHook attribute) (airflow.hooks.druid_hook.DruidDbApiHook attribute) (airflow.hooks.jdbc_hook.JdbcHook attribute) (airflow.hooks.mssql_hook.MsSqlHook attribute) (airflow.hooks.mysql_hook.MySqlHook attribute) (airflow.hooks.oracle_hook.OracleHook attribute) (airflow.hooks.postgres_hook.PostgresHook attribute) (airflow.hooks.presto_hook.PrestoHook attribute) (airflow.hooks.sqlite_hook.SqliteHook attribute) conn_type (airflow.contrib.hooks.mongo_hook.MongoHook attribute) (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) Connection (class in airflow.models) (class in airflow.models.connection) CONNECTION_URIS (in module airflow.contrib.hooks.gcp_sql_hook) connector (airflow.hooks.dbapi_hook.DbApiHook attribute) 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_array_types() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class 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_type() (airflow.contrib.operators.mssql_to_gcs.MsSqlToGoogleCloudStorageOperator class method) (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator method) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) convert_types() (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) convert_user_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) convert_value() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) copy() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) copy_expert() (airflow.hooks.postgres_hook.PostgresHook method) copy_object() (airflow.hooks.S3_hook.S3Hook method) core_section (airflow.contrib.executors.kubernetes_executor.KubeConfig attribute) CQL_TYPE_MAP (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator attribute) create_bucket() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) (airflow.hooks.S3_hook.S3Hook method) create_build() (airflow.contrib.hooks.gcp_cloud_build_hook.CloudBuildHook method) create_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method) create_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method) create_cmd_args() (airflow.contrib.hooks.qubole_hook.QuboleHook method) create_collection() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) create_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) create_dagrun() (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.DagModel method) create_database() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) create_deidentify_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) create_directory() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) create_dlp_job() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) create_empty_dataset() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) create_empty_table() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) create_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) create_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) create_external_table() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) create_inspect_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) create_instance() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook method) (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) create_integer_fields() (airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator method) (airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator method) create_job() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) create_job_flow() (airflow.contrib.hooks.emr_hook.EmrHook method) create_job_template() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) (airflow.contrib.operators.dataproc_operator.DataProcJobBaseOperator method) create_job_trigger() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) create_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) create_new_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) create_or_update() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) create_product() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) create_product_set() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) create_queue() (airflow.contrib.hooks.aws_sqs_hook.SQSHook method) create_reference_image() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) create_stored_info_type() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) create_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) create_table() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook static method) create_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) create_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) create_transfer_job() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) create_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) create_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) create_tunnel() (airflow.contrib.hooks.ssh_hook.SSHHook method) create_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) created_dttm (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) current_state() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) cursor() (airflow.contrib.hooks.bigquery_hook.BigQueryConnection method) CYCLE_DONE (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) CYCLE_IN_PROGRESS (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) CYCLE_NEW (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute)

D

dag (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.operators.BaseOperator attribute) DAG (class in airflow.models) (class in airflow.models.dag) dag_id (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) (airflow.operators.BaseOperator attribute) dag_ids (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) DagBag (class in airflow.models) (class in airflow.models.dagbag) DAGBAG_IMPORT_TIMEOUT (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) dagbag_report() (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) DagModel (class in airflow.models) (class in airflow.models.dag) DagPickle (class in airflow.models) (class in airflow.models.dagpickle) DagRun (class in airflow.models) (class in airflow.models.dagrun) DagRunOrder (class in airflow.operators.dagrun_operator) DaskExecutor (airflow.executors.Executors attribute) (class in airflow.executors.dask_executor) DatabricksHook (class in airflow.contrib.hooks.databricks_hook) DatabricksRunNowOperator (class in airflow.contrib.operators.databricks_operator) DatabricksSubmitRunOperator (class in airflow.contrib.operators.databricks_operator) 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) DataFlowJavaOperator (class in airflow.contrib.operators.dataflow_operator) DataFlowPythonOperator (class in airflow.contrib.operators.dataflow_operator) DataflowTemplateOperator (class in airflow.contrib.operators.dataflow_operator) DataprocClusterCreateOperator (class in airflow.contrib.operators.dataproc_operator) DataprocClusterDeleteOperator (class in airflow.contrib.operators.dataproc_operator) DataprocClusterScaleOperator (class in airflow.contrib.operators.dataproc_operator) DataProcHadoopOperator (class in airflow.contrib.operators.dataproc_operator) DataProcHiveOperator (class in airflow.contrib.operators.dataproc_operator) DataProcHook (class in airflow.contrib.hooks.gcp_dataproc_hook) DataProcJobBaseOperator (class in airflow.contrib.operators.dataproc_operator) DataprocOperationBaseOperator (class in airflow.contrib.operators.dataproc_operator) DataProcPigOperator (class in airflow.contrib.operators.dataproc_operator) DataProcPySparkOperator (class in airflow.contrib.operators.dataproc_operator) DataProcSparkOperator (class in airflow.contrib.operators.dataproc_operator) DataProcSparkSqlOperator (class in airflow.contrib.operators.dataproc_operator) DataprocWorkflowTemplateInstantiateInlineOperator (class in airflow.contrib.operators.dataproc_operator) DataprocWorkflowTemplateInstantiateOperator (class in airflow.contrib.operators.dataproc_operator) DatastoreExportOperator (class in airflow.contrib.operators.datastore_export_operator) DatastoreHook (class in airflow.contrib.hooks.datastore_hook) DatastoreImportOperator (class in airflow.contrib.operators.datastore_import_operator) date_range() (airflow.models.DAG method) (airflow.models.dag.DAG method) datetime_diff_for_humans() (in module airflow.macros) DAY (in module airflow.contrib.hooks.gcp_transfer_hook) 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) (airflow.models.dag.DAG static method) deactivate_unknown_dags() (airflow.models.DAG static method) (airflow.models.dag.DAG static method) debug_info() (airflow.models.Connection method) (airflow.models.connection.Connection method) decrypt() (airflow.contrib.hooks.gcp_kms_hook.GoogleCloudKMSHook method) (airflow.models.crypto.NullFernet method) default_conn_name (airflow.contrib.hooks.pinot_hook.PinotDbApiHook attribute) (airflow.contrib.hooks.snowflake_hook.SnowflakeHook attribute) (airflow.contrib.hooks.vertica_hook.VerticaHook attribute) (airflow.hooks.dbapi_hook.DbApiHook attribute) (airflow.hooks.druid_hook.DruidDbApiHook attribute) (airflow.hooks.jdbc_hook.JdbcHook attribute) (airflow.hooks.mssql_hook.MsSqlHook attribute) (airflow.hooks.mysql_hook.MySqlHook attribute) (airflow.hooks.oracle_hook.OracleHook attribute) (airflow.hooks.postgres_hook.PostgresHook attribute) (airflow.hooks.presto_hook.PrestoHook attribute) (airflow.hooks.sqlite_hook.SqliteHook attribute) DEFAULT_CPU (in module airflow.contrib.operators.azure_container_instances_operator) DEFAULT_DATAFLOW_LOCATION (in module airflow.contrib.hooks.gcp_dataflow_hook) DEFAULT_ENVIRONMENT_VARIABLES (in module airflow.contrib.operators.azure_container_instances_operator) DEFAULT_EXECUTOR (in module airflow.executors) DEFAULT_FRAMEWORK_NAME (in module airflow.contrib.executors.mesos_executor) DEFAULT_MEMORY_IN_GB (in module airflow.contrib.operators.azure_container_instances_operator) default_params (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) DEFAULT_POOL_NAME (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) DEFAULT_SECURED_VARIABLES (in module airflow.contrib.operators.azure_container_instances_operator) DEFAULT_TARGET_PARTITION_SIZE (in module airflow.operators.hive_to_druid) default_view (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) DEFAULT_VOLUMES (in module airflow.contrib.operators.azure_container_instances_operator) deidentify_content() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) delete() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) (airflow.models.Variable class method) (airflow.models.variable.Variable class method) (airflow.models.XCom class method) (airflow.models.xcom.XCom class method)

delete_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method) (airflow.contrib.hooks.redshift_hook.RedshiftHook method) delete_collection() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) delete_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) delete_database() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) delete_dataset() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) delete_deidentify_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) delete_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) delete_dlp_job() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) delete_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) delete_file() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) (airflow.contrib.hooks.wasb_hook.WasbHook method) delete_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) delete_inspect_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) delete_instance() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook method) (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) delete_job_trigger() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) delete_many() (airflow.contrib.hooks.mongo_hook.MongoHook method) delete_objects() (airflow.hooks.S3_hook.S3Hook method) delete_one() (airflow.contrib.hooks.mongo_hook.MongoHook method) delete_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) delete_pod() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) delete_product() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) delete_product_set() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) delete_reference_image() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) delete_stored_info_type() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) delete_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) delete_table() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook method) delete_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) delete_transfer_job() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) delete_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) DELETED (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferJobsStatus attribute) DEPLOY_FUNCTION (airflow.contrib.hooks.openfaas_hook.OpenFaasHook attribute) deploy_function() (airflow.contrib.hooks.openfaas_hook.OpenFaasHook method) deps (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) (airflow.sensors.base_sensor_operator.BaseSensorOperator attribute) describe_cluster_snapshots() (airflow.contrib.hooks.redshift_hook.RedshiftHook method) 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) describe_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) describe_model() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) describe_object() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) describe_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) describe_training_job_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) describe_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) describe_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) description (airflow.contrib.hooks.bigquery_hook.BigQueryCursor attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) DESCRIPTION (in module airflow.contrib.hooks.gcp_transfer_hook) DingdingHook (class in airflow.contrib.hooks.dingding_hook) DingdingOperator (class in airflow.contrib.operators.dingding_operator) DISABLED (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferJobsStatus attribute) disconnected() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) DiscordWebhookHook (class in airflow.contrib.hooks.discord_webhook_hook) DiscordWebhookOperator (class in airflow.contrib.operators.discord_webhook_operator) DLP_JOB_PATH_PATTERN (in module airflow.contrib.hooks.gcp_dlp_hook) DockerHook (class in airflow.hooks.docker_hook) DockerOperator (class in airflow.operators.docker_operator) document_text_detection() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) does_collection_exist() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) does_database_exist() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) does_function_exist() (airflow.contrib.hooks.openfaas_hook.OpenFaasHook method) DONE (airflow.contrib.hooks.gcp_compute_hook.GceOperationStatus attribute) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlOperationStatus attribute) download() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) download_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method) download_mail_attachments() (airflow.contrib.hooks.imap_hook.ImapHook method) downstream_list (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) downstream_task_ids (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) 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) dry_run() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.operators.BaseOperator method) (airflow.operators.hive_operator.HiveOperator method) ds_add() (in module airflow.macros) ds_format() (in module airflow.macros) dttm (airflow.models.Log attribute) (airflow.models.log.Log attribute) DummyOperator (class in airflow.operators.dummy_operator) duration (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute)

E

ECSOperator (class in airflow.contrib.operators.ecs_operator) email (airflow.models.User attribute) (airflow.models.user.User attribute) email_alert() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) email_sent (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) EmailOperator (class in airflow.operators.email_operator) EmrAddStepsOperator (class in airflow.contrib.operators.emr_add_steps_operator) EmrBaseSensor (class in airflow.contrib.sensors.emr_base_sensor) EmrCreateJobFlowOperator (class in airflow.contrib.operators.emr_create_job_flow_operator) EmrHook (class in airflow.contrib.hooks.emr_hook) 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) ENABLED (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferJobsStatus attribute) encrypt() (airflow.contrib.hooks.gcp_kms_hook.GoogleCloudKMSHook method) (airflow.models.crypto.NullFernet method) end() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor._LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor._UnlimitedParallelism method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) (airflow.executors.sequential_executor.SequentialExecutor method) (airflow.executors.SequentialExecutor method) end_date (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) endpoint_non_terminal_states (airflow.contrib.hooks.sagemaker_hook.SageMakerHook attribute) error() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) error_code_pattern (airflow.contrib.sensors.ftp_sensor.FTPSensor attribute) event (airflow.models.Log attribute) (airflow.models.log.Log attribute) event_type (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) ExceptionWithTraceback (class in airflow.executors.celery_executor) execute() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) (airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook method) (airflow.contrib.hooks.opsgenie_alert_hook.OpsgenieAlertHook method) (airflow.contrib.hooks.qubole_hook.QuboleHook method) (airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook method) (airflow.contrib.operators.adls_list_operator.AzureDataLakeStorageListOperator method) (airflow.contrib.operators.adls_to_gcs.AdlsToGoogleCloudStorageOperator method) (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method) (airflow.contrib.operators.aws_sqs_publish_operator.SQSPublishOperator method) (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator method) (airflow.contrib.operators.azure_container_instances_operator.AzureContainerInstancesOperator method) (airflow.contrib.operators.azure_cosmos_operator.AzureCosmosInsertDocumentOperator method) (airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyDatasetOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryGetDatasetOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryPatchDatasetOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryUpdateDatasetOperator method) (airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator method) (airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator method) (airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator method) (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator method) (airflow.contrib.operators.databricks_operator.DatabricksRunNowOperator method) (airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator method) (airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator method) (airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator method) (airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator method) (airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator method) (airflow.contrib.operators.dataproc_operator.DataProcHiveOperator method) (airflow.contrib.operators.dataproc_operator.DataProcJobBaseOperator method) (airflow.contrib.operators.dataproc_operator.DataprocOperationBaseOperator method) (airflow.contrib.operators.dataproc_operator.DataProcPigOperator method) (airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator method) (airflow.contrib.operators.dataproc_operator.DataProcSparkOperator method) (airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator method) (airflow.contrib.operators.datastore_export_operator.DatastoreExportOperator method) (airflow.contrib.operators.datastore_import_operator.DatastoreImportOperator method) (airflow.contrib.operators.dingding_operator.DingdingOperator method) (airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator method) (airflow.contrib.operators.druid_operator.DruidOperator method) (airflow.contrib.operators.ecs_operator.ECSOperator method) (airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator method) (airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator method) (airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator method) (airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator method) (airflow.contrib.operators.file_to_wasb.FileToWasbOperator method) (airflow.contrib.operators.gcp_bigtable_operator.BigtableClusterUpdateOperator method) (airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceCreateOperator method) (airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceDeleteOperator method) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableCreateOperator method) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableDeleteOperator method) (airflow.contrib.operators.gcp_cloud_build_operator.CloudBuildCreateBuildOperator method) (airflow.contrib.operators.gcp_compute_operator.GceBaseOperator method) (airflow.contrib.operators.gcp_compute_operator.GceInstanceGroupManagerUpdateTemplateOperator method) (airflow.contrib.operators.gcp_compute_operator.GceInstanceStartOperator method) (airflow.contrib.operators.gcp_compute_operator.GceInstanceStopOperator method) (airflow.contrib.operators.gcp_compute_operator.GceInstanceTemplateCopyOperator method) (airflow.contrib.operators.gcp_compute_operator.GceSetMachineTypeOperator method) (airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator method) (airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator method) (airflow.contrib.operators.gcp_container_operator.GKEPodOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCancelDLPJobOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateDeidentifyTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateDLPJobOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateInspectTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateJobTriggerOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateStoredInfoTypeOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeidentifyContentOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteDeidentifyTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteDlpJobOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteInspectTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteJobTriggerOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteStoredInfoTypeOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetDeidentifyTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetDlpJobOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetInspectTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetJobTripperOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetStoredInfoTypeOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPInspectContentOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListDeidentifyTemplatesOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListDlpJobsOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListInfoTypesOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListInspectTemplatesOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListJobTriggersOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListStoredInfoTypesOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPRedactImageOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPReidentifyContentOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateDeidentifyTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateInspectTemplateOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateJobTriggerOperator method) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateStoredInfoTypeOperator method) (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeleteOperator method) (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageAnalyzeEntitiesOperator method) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageAnalyzeEntitySentimentOperator method) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageAnalyzeSentimentOperator method) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageClassifyTextOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeleteOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeployOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseQueryOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseUpdateOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeleteOperator method) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeployOperator method) (airflow.contrib.operators.gcp_speech_to_text_operator.GcpSpeechToTextRecognizeSpeechOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlBaseOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseDeleteOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDeleteOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceExportOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceImportOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstancePatchOperator method) (airflow.contrib.operators.gcp_sql_operator.CloudSqlQueryOperator method) (airflow.contrib.operators.gcp_text_to_speech_operator.GcpTextToSpeechSynthesizeOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobCreateOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobDeleteOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobUpdateOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationCancelOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationGetOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationPauseOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationResumeOperator method) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationsListOperator method) (airflow.contrib.operators.gcp_transfer_operator.GoogleCloudStorageToGoogleCloudStorageTransferOperator method) (airflow.contrib.operators.gcp_transfer_operator.S3ToGoogleCloudStorageTransferOperator method) (airflow.contrib.operators.gcp_translate_operator.CloudTranslateTextOperator method) (airflow.contrib.operators.gcp_translate_speech_operator.GcpTranslateSpeechOperator method) (airflow.contrib.operators.gcp_video_intelligence_operator.CloudVideoIntelligenceDetectVideoExplicitContentOperator method) (airflow.contrib.operators.gcp_video_intelligence_operator.CloudVideoIntelligenceDetectVideoLabelsOperator method) (airflow.contrib.operators.gcp_video_intelligence_operator.CloudVideoIntelligenceDetectVideoShotsOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionAddProductToProductSetOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionAnnotateImageOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectDocumentTextOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectImageLabelsOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectImageSafeSearchOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectTextOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductCreateOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductDeleteOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductGetOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetCreateOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetDeleteOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetGetOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetUpdateOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductUpdateOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionReferenceImageCreateOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionRemoveProductFromProductSetOperator method) (airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageBucketCreateAclEntryOperator method) (airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageObjectCreateAclEntryOperator method) (airflow.contrib.operators.gcs_delete_operator.GoogleCloudStorageDeleteOperator method) (airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator method) (airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator method) (airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator method) (airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator method) (airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator method) (airflow.contrib.operators.gcs_to_s3.GoogleCloudStorageToS3Operator method) (airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method) (airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBTransferOperator method) (airflow.contrib.operators.imap_attachment_to_s3_operator.ImapAttachmentToS3Operator method) (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method) (airflow.contrib.operators.jira_operator.JiraOperator method) (airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator method) (airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator method) (airflow.contrib.operators.mlengine_operator.MLEngineModelOperator method) (airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator method) (airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator method) (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator method) (airflow.contrib.operators.opsgenie_alert_operator.OpsgenieAlertOperator method) (airflow.contrib.operators.oracle_to_azure_data_lake_transfer.OracleToAzureDataLakeTransfer method) (airflow.contrib.operators.oracle_to_oracle_transfer.OracleToOracleTransfer method) (airflow.contrib.operators.pubsub_operator.PubSubPublishOperator method) (airflow.contrib.operators.pubsub_operator.PubSubSubscriptionCreateOperator method) (airflow.contrib.operators.pubsub_operator.PubSubSubscriptionDeleteOperator method) (airflow.contrib.operators.pubsub_operator.PubSubTopicCreateOperator method) (airflow.contrib.operators.pubsub_operator.PubSubTopicDeleteOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator method) (airflow.contrib.operators.qubole_operator.QuboleOperator method) (airflow.contrib.operators.redis_publish_operator.RedisPublishOperator method) (airflow.contrib.operators.s3_copy_object_operator.S3CopyObjectOperator method) (airflow.contrib.operators.s3_delete_objects_operator.S3DeleteObjectsOperator method) (airflow.contrib.operators.s3_list_operator.S3ListOperator method) (airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator method) (airflow.contrib.operators.s3_to_sftp_operator.S3ToSFTPOperator method) (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator method) (airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator method) (airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator method) (airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator method) (airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator method) (airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator method) (airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator method) (airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator method) (airflow.contrib.operators.sftp_operator.SFTPOperator method) (airflow.contrib.operators.sftp_to_s3_operator.SFTPToS3Operator method) (airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator method) (airflow.contrib.operators.snowflake_operator.SnowflakeOperator method) (airflow.contrib.operators.sns_publish_operator.SnsPublishOperator 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.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) (airflow.contrib.operators.sqoop_operator.SqoopOperator method) (airflow.contrib.operators.ssh_operator.SSHOperator method) (airflow.contrib.operators.vertica_operator.VerticaOperator method) (airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer method) (airflow.contrib.operators.vertica_to_mysql.VerticaToMySqlTransfer method) (airflow.contrib.operators.wasb_delete_blob_operator.WasbDeleteBlobOperator method) (airflow.contrib.operators.winrm_operator.WinRMOperator method) (airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) (airflow.operators.bash_operator.BashOperator method) (airflow.operators.branch_operator.BaseBranchOperator method) (airflow.operators.check_operator.CheckOperator method) (airflow.operators.check_operator.IntervalCheckOperator method) (airflow.operators.check_operator.ValueCheckOperator method) (airflow.operators.dagrun_operator.TriggerDagRunOperator method) (airflow.operators.docker_operator.DockerOperator method) (airflow.operators.druid_check_operator.DruidCheckOperator method) (airflow.operators.dummy_operator.DummyOperator method) (airflow.operators.email_operator.EmailOperator method) (airflow.operators.generic_transfer.GenericTransfer method) (airflow.operators.hive_operator.HiveOperator method) (airflow.operators.hive_stats_operator.HiveStatsCollectionOperator method) (airflow.operators.hive_to_druid.HiveToDruidTransfer method) (airflow.operators.hive_to_mysql.HiveToMySqlTransfer method) (airflow.operators.hive_to_samba_operator.Hive2SambaOperator method) (airflow.operators.http_operator.SimpleHttpOperator method) (airflow.operators.jdbc_operator.JdbcOperator method) (airflow.operators.latest_only_operator.LatestOnlyOperator method) (airflow.operators.mssql_operator.MsSqlOperator method) (airflow.operators.mssql_to_hive.MsSqlToHiveTransfer method) (airflow.operators.mysql_operator.MySqlOperator method) (airflow.operators.mysql_to_hive.MySqlToHiveTransfer method) (airflow.operators.oracle_operator.OracleOperator method) (airflow.operators.papermill_operator.PapermillOperator method) (airflow.operators.pig_operator.PigOperator method) (airflow.operators.postgres_operator.PostgresOperator method) (airflow.operators.presto_to_mysql.PrestoToMySqlTransfer method) (airflow.operators.python_operator.BranchPythonOperator method) (airflow.operators.python_operator.PythonOperator method) (airflow.operators.python_operator.ShortCircuitOperator method) (airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer method) (airflow.operators.s3_file_transform_operator.S3FileTransformOperator method) (airflow.operators.s3_to_hive_operator.S3ToHiveTransfer method) (airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer method) (airflow.operators.slack_operator.SlackAPIOperator method) (airflow.operators.sqlite_operator.SqliteOperator method) (airflow.operators.subdag_operator.SubDagOperator method) (airflow.sensors.base_sensor_operator.BaseSensorOperator method)

execute_async() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor._LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor._UnlimitedParallelism method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) (airflow.executors.sequential_executor.SequentialExecutor method) (airflow.executors.SequentialExecutor method) execute_callable() (airflow.operators.python_operator.PythonOperator method) (airflow.operators.python_operator.PythonVirtualenvOperator method) execute_command() (in module airflow.executors.celery_executor) execute_dml() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) execute_work() (airflow.executors.local_executor.LocalWorker method) executemany() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) execution_date (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) executor_config (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) executorLost() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) Executors (class in airflow.executors) exists() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) expand_role() (airflow.contrib.hooks.aws_hook.AwsHook method) (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator method) (airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator method) (airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator method) (airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator method) (airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator method) (airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator 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) external_trigger (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) ExternalTaskSensor (class in airflow.operators.sensors) (class in airflow.sensors.external_task_sensor) extra (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) extra_dejson (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) extra_links() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method)

F

fail() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) FAILED (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferOperationStatus attribute) FAILED_STATE (airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor attribute) (airflow.contrib.sensors.emr_step_sensor.EmrStepSensor attribute) failed_states (airflow.contrib.hooks.sagemaker_hook.SageMakerHook attribute) failed_states() (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method) (airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor method) (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor method) (airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor method) (airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor method) failure_message_from_response() (airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor static method) (airflow.contrib.sensors.emr_step_sensor.EmrStepSensor static method) FAILURE_STATES (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook attribute) (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor attribute) fallback_to_default_project_id() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook static method) fetch_celery_task_state() (in module airflow.executors.celery_executor) fetchall() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) fetchmany() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) fetchone() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) field_to_bigquery() (airflow.contrib.operators.mssql_to_gcs.MsSqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator method) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method) fileloc (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) filename (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) filepath (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) FileSensor (class in airflow.contrib.sensors.file_sensor)

FileToGoogleCloudStorageOperator (class in airflow.contrib.operators.file_to_gcs) FileToWasbOperator (class in airflow.contrib.operators.file_to_wasb) FILTER (in module airflow.contrib.hooks.gcp_transfer_hook) filter_for_filesize() (airflow.sensors.hdfs_sensor.HdfsSensor static method) filter_for_ignored_ext() (airflow.sensors.hdfs_sensor.HdfsSensor static method) FILTER_JOB_NAMES (in module airflow.contrib.hooks.gcp_transfer_hook) filter_options() (in module airflow.contrib.hooks.qubole_hook) FILTER_PROJECT_ID (in module airflow.contrib.hooks.gcp_transfer_hook) find() (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.models.DagRun static method) (airflow.models.dagrun.DagRun static method) find_for_task_instance() (airflow.models.TaskReschedule static method) (airflow.models.taskreschedule.TaskReschedule static method) flatten_list() (in module airflow.contrib.hooks.qubole_hook) folder (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) following_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) FRAMEWORK_CONNID_PREFIX (in module airflow.contrib.executors.mesos_executor) frameworkMessage() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) free_reserved_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) from_dict() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutorConfig static 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) full_filepath (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) FUNCTION_NAME_COMPILED_PATTERN (in module airflow.contrib.operators.gcp_function_operator) FUNCTION_NAME_PATTERN (in module airflow.contrib.operators.gcp_function_operator)

G

GCE_INSTANCE_TEMPLATE_FIELDS_TO_SANITIZE (in module airflow.contrib.operators.gcp_compute_operator) GCE_INSTANCE_TEMPLATE_VALIDATION_PATCH_SPECIFICATION (in module airflow.contrib.operators.gcp_compute_operator) 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) GceOperationStatus (class in airflow.contrib.hooks.gcp_compute_hook) GceSetMachineTypeOperator (class in airflow.contrib.operators.gcp_compute_operator) GCF_SOURCE_ARCHIVE_URL (in module airflow.contrib.operators.gcp_function_operator) GCF_SOURCE_UPLOAD_URL (in module airflow.contrib.operators.gcp_function_operator) GCF_ZIP_PATH (in module airflow.contrib.operators.gcp_function_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) GCP_CREDENTIALS_KEY_PATH (in module airflow.contrib.hooks.gcp_sql_hook) GCP_CREDENTIALS_KEYFILE_DICT (in module airflow.contrib.hooks.gcp_sql_hook) GCPSpeechToTextHook (class in airflow.contrib.hooks.gcp_speech_to_text_hook) GcpSpeechToTextRecognizeSpeechOperator (class in airflow.contrib.operators.gcp_speech_to_text_operator) GCPTextToSpeechHook (class in airflow.contrib.hooks.gcp_text_to_speech_hook) GcpTextToSpeechSynthesizeOperator (class in airflow.contrib.operators.gcp_text_to_speech_operator) GcpTransferJobsStatus (class in airflow.contrib.hooks.gcp_transfer_hook) GcpTransferOperationStatus (class in airflow.contrib.hooks.gcp_transfer_hook) GCPTransferServiceHook (class in airflow.contrib.hooks.gcp_transfer_hook) GcpTransferServiceJobCreateOperator (class in airflow.contrib.operators.gcp_transfer_operator) GcpTransferServiceJobDeleteOperator (class in airflow.contrib.operators.gcp_transfer_operator) GcpTransferServiceJobUpdateOperator (class in airflow.contrib.operators.gcp_transfer_operator) GcpTransferServiceOperationCancelOperator (class in airflow.contrib.operators.gcp_transfer_operator) GcpTransferServiceOperationGetOperator (class in airflow.contrib.operators.gcp_transfer_operator) GcpTransferServiceOperationPauseOperator (class in airflow.contrib.operators.gcp_transfer_operator) GcpTransferServiceOperationResumeOperator (class in airflow.contrib.operators.gcp_transfer_operator) GcpTransferServiceOperationsListOperator (class in airflow.contrib.operators.gcp_transfer_operator) GCPTransferServiceWaitForJobStatusSensor (class in airflow.contrib.sensors.gcp_transfer_sensor) GcpTranslateSpeechOperator (class in airflow.contrib.operators.gcp_translate_speech_operator) GCS_DATA_SINK (in module airflow.contrib.hooks.gcp_transfer_hook) GCS_DATA_SOURCE (in module airflow.contrib.hooks.gcp_transfer_hook) GCS_PREFIX_LENGTH (airflow.contrib.operators.dataflow_operator.GoogleCloudBucketHelper attribute) generate_command() (airflow.models.TaskInstance static method) (airflow.models.taskinstance.TaskInstance static method) generate_data_dict() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) generate_schema_dict() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) GenericTransfer (class in airflow.operators.generic_transfer) GET (airflow.contrib.operators.sftp_operator.SFTPOperation attribute) get() (airflow.contrib.hooks.gcp_dataflow_hook._DataflowJob method) (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJob method) (airflow.contrib.hooks.gcp_dataproc_hook._DataProcOperation method) (airflow.models.Variable class method) (airflow.models.variable.Variable class method) get_active_runs() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_arraysize() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) get_attachments_by_name() (airflow.contrib.hooks.imap_hook.Mail method) get_autocommit() (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.mssql_hook.MsSqlHook method) (airflow.hooks.mysql_hook.MySqlHook method) get_available_fields() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) get_bq_fields() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) get_bq_mode() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) get_bq_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) get_bucket() (airflow.hooks.S3_hook.S3Hook method) get_client() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method) get_client_type() (airflow.contrib.hooks.aws_hook.AwsHook method) get_cluster() (airflow.contrib.hooks.cassandra_hook.CassandraHook method) (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method) (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) get_cluster_states_for_table() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook static method) get_collection() (airflow.contrib.hooks.mongo_hook.MongoHook method) get_collection_link() (in module airflow.contrib.hooks.azure_cosmos_hook) get_column_families_for_table() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook static method) get_command() (airflow.operators.docker_operator.DockerOperator method) get_conn() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) (airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook method) (airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method) (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method) (airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook method) (airflow.contrib.hooks.aws_logs_hook.AwsLogsHook method) (airflow.contrib.hooks.aws_sns_hook.AwsSnsHook method) (airflow.contrib.hooks.aws_sqs_hook.SQSHook method) (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) (airflow.contrib.hooks.azure_container_registry_hook.AzureContainerRegistryHook method) (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method) (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) (airflow.contrib.hooks.bigquery_hook.BigQueryHook method) (airflow.contrib.hooks.cassandra_hook.CassandraHook method) (airflow.contrib.hooks.cloudant_hook.CloudantHook method) (airflow.contrib.hooks.datastore_hook.DatastoreHook method) (airflow.contrib.hooks.dingding_hook.DingdingHook method) (airflow.contrib.hooks.emr_hook.EmrHook method) (airflow.contrib.hooks.fs_hook.FSHook method) (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.ftp_hook.FTPSHook method) (airflow.contrib.hooks.gcp_cloud_build_hook.CloudBuildHook method) (airflow.contrib.hooks.gcp_compute_hook.GceHook method) (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method) (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) (airflow.contrib.hooks.gcp_function_hook.GcfHook method) (airflow.contrib.hooks.gcp_kms_hook.GoogleCloudKMSHook method) (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) (airflow.contrib.hooks.gcp_natural_language_hook.CloudNaturalLanguageHook method) (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) (airflow.contrib.hooks.gcp_speech_to_text_hook.GCPSpeechToTextHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) (airflow.contrib.hooks.gcp_text_to_speech_hook.GCPTextToSpeechHook method) (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) (airflow.contrib.hooks.gcp_translate_hook.CloudTranslateHook method) (airflow.contrib.hooks.gcp_video_intelligence_hook.CloudVideoIntelligenceHook method) (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) (airflow.contrib.hooks.grpc_hook.GrpcHook method) (airflow.contrib.hooks.jira_hook.JiraHook method) (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.contrib.hooks.openfaas_hook.OpenFaasHook method) (airflow.contrib.hooks.opsgenie_alert_hook.OpsgenieAlertHook method) (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.contrib.hooks.redis_hook.RedisHook method) (airflow.contrib.hooks.redshift_hook.RedshiftHook method) (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) (airflow.contrib.hooks.segment_hook.SegmentHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) (airflow.contrib.hooks.snowflake_hook.SnowflakeHook method) (airflow.contrib.hooks.spark_jdbc_hook.SparkJDBCHook method) (airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method) (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) (airflow.contrib.hooks.sqoop_hook.SqoopHook method) (airflow.contrib.hooks.ssh_hook.SSHHook method) (airflow.contrib.hooks.vertica_hook.VerticaHook method) (airflow.contrib.hooks.wasb_hook.WasbHook method) (airflow.contrib.hooks.winrm_hook.WinRMHook method) (airflow.hooks.base_hook.BaseHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.docker_hook.DockerHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) (airflow.hooks.hdfs_hook.HDFSHook method) (airflow.hooks.hive_hooks.HiveMetastoreHook method) (airflow.hooks.hive_hooks.HiveServer2Hook method) (airflow.hooks.http_hook.HttpHook method) (airflow.hooks.jdbc_hook.JdbcHook method) (airflow.hooks.mssql_hook.MsSqlHook method) (airflow.hooks.mysql_hook.MySqlHook method) (airflow.hooks.oracle_hook.OracleHook method) (airflow.hooks.postgres_hook.PostgresHook method) (airflow.hooks.presto_hook.PrestoHook method) (airflow.hooks.S3_hook.S3Hook method) (airflow.hooks.samba_hook.SambaHook method) (airflow.hooks.sqlite_hook.SqliteHook method) (airflow.hooks.webhdfs_hook.WebHDFSHook method) (airflow.hooks.zendesk_hook.ZendeskHook method) get_conn_url() (airflow.hooks.druid_hook.DruidHook method) get_connection() (airflow.hooks.base_hook.BaseHook class method) get_connections() (airflow.hooks.base_hook.BaseHook class method) get_context_from_env_var() (in module airflow.hooks.hive_hooks) get_crc32c() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) get_credentials() (airflow.contrib.hooks.aws_hook.AwsHook method) get_current() (airflow.models.dag.DagModel class method) (airflow.models.DagModel class method) get_current_resource_version() (airflow.models.KubeResourceVersion static method) (airflow.models.kubernetes.KubeResourceVersion static method) get_cursor() (airflow.hooks.dbapi_hook.DbApiHook method) get_dag() (airflow.models.dag.DagModel method) (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) (airflow.models.DagModel method) (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_dagmodel() (airflow.models.dag.DagModel static method) (airflow.models.DagModel static method) get_dagrun() (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_dagruns_between() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_database() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) get_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) get_database_link() (in module airflow.contrib.hooks.azure_cosmos_hook) get_databases() (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_dataset() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) get_datasets_list() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) get_db_hook() (airflow.contrib.operators.bigquery_check_operator.BigQueryCheckOperator method) (airflow.contrib.operators.bigquery_check_operator.BigQueryIntervalCheckOperator method) (airflow.contrib.operators.bigquery_check_operator.BigQueryValueCheckOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator method) (airflow.operators.check_operator.CheckOperator method) (airflow.operators.check_operator.IntervalCheckOperator method) (airflow.operators.check_operator.ValueCheckOperator method) (airflow.operators.druid_check_operator.DruidCheckOperator method) (airflow.operators.presto_check_operator.PrestoCheckOperator method) (airflow.operators.presto_check_operator.PrestoIntervalCheckOperator method) (airflow.operators.presto_check_operator.PrestoValueCheckOperator method) get_default_executor() (in module airflow.executors) get_default_exprs() (airflow.operators.hive_stats_operator.HiveStatsCollectionOperator method) get_default_pool() (airflow.models.Pool static method) (airflow.models.pool.Pool static method) get_default_view() (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.DagModel method) get_deidentify_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) get_direct_relative_ids() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) get_direct_relatives() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) get_dlp_job() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) get_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) get_document_link() (in module airflow.contrib.hooks.azure_cosmos_hook) get_documents() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) get_emr_response() (airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor method) (airflow.contrib.sensors.emr_step_sensor.EmrStepSensor method) get_entity_with_name() (airflow.contrib.hooks.gcp_vision_hook.NameDeterminer method) get_event_buffer() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) get_extra() (airflow.models.Connection method) (airflow.models.connection.Connection method) get_extra_links() (airflow.contrib.hooks.qubole_hook.QuboleHook method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method)

get_failed_dep_statuses() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_failed_reason_from_response() (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method) (airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor method) (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor method) (airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor method) (airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor method) get_fernet() (in module airflow.models.crypto) get_file() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) (airflow.contrib.hooks.imap_hook.MailPart method) (airflow.contrib.hooks.wasb_hook.WasbHook method) get_file_to_stream() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) get_file_volume() (airflow.contrib.hooks.azure_container_volume_hook.AzureContainerVolumeHook method) get_first() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.contrib.hooks.qubole_check_hook.QuboleCheckHook 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) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) get_flat_relatives() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) get_framework_name() (in module airflow.contrib.executors.mesos_executor) GET_FUNCTION (airflow.contrib.hooks.openfaas_hook.OpenFaasHook attribute) get_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) get_hook() (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method) (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator method) (airflow.contrib.operators.databricks_operator.DatabricksRunNowOperator method) (airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator method) (airflow.contrib.operators.ecs_operator.ECSOperator method) (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator method) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator method) (airflow.contrib.operators.qubole_operator.QuboleOperator method) (airflow.contrib.operators.snowflake_operator.SnowflakeOperator method) (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor method) (airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor method) (airflow.hooks.base_hook.BaseHook class method) (airflow.models.Connection method) (airflow.models.connection.Connection method) (airflow.operators.docker_operator.DockerOperator method) (airflow.operators.hive_operator.HiveOperator method) (airflow.operators.pig_operator.PigOperator method) get_iam_token() (airflow.hooks.mysql_hook.MySqlHook method) (airflow.hooks.postgres_hook.PostgresHook method) get_id() (airflow.models.User method) (airflow.models.user.User method) get_inspect_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) get_instance() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook method) (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) (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_jenkins_server() (airflow.contrib.hooks.jenkins_hook.JenkinsHook method) get_job_trigger() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) get_jobs_id() (airflow.contrib.hooks.qubole_hook.QuboleHook method) (airflow.contrib.operators.qubole_operator.QuboleOperator method) get_key() (airflow.hooks.S3_hook.S3Hook method) get_last_dagrun() (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.DagModel method) (in module airflow.models.dag) get_latest_runs() (airflow.models.DagRun class method) (airflow.models.dagrun.DagRun class method) get_lb_policy() (airflow.contrib.hooks.cassandra_hook.CassandraHook static method) get_link() (airflow.contrib.operators.bigquery_operator.BigQueryConsoleLink method) (airflow.contrib.operators.qubole_operator.QDSLink method) (airflow.models.baseoperator.BaseOperatorLink method) get_log() (airflow.contrib.hooks.qubole_hook.QuboleHook method) (airflow.contrib.operators.qubole_operator.QuboleOperator method) get_log_conn() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) get_log_events() (airflow.contrib.hooks.aws_logs_hook.AwsLogsHook method) get_logs() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) get_logs_hook() (airflow.contrib.operators.ecs_operator.ECSOperator method) get_many() (airflow.models.XCom class method) (airflow.models.xcom.XCom class method) get_md5hash() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) get_messages() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) get_metastore_client() (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_mod_time() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) get_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) get_num_active_runs() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_num_running_task_instances() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_num_task_instances() (airflow.models.DAG static method) (airflow.models.dag.DAG static method) get_object_from_salesforce() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) get_one() (airflow.models.XCom class method) (airflow.models.xcom.XCom class method) get_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method) get_options_list() (in module airflow.contrib.hooks.qubole_hook) get_or_create_current_kube_worker_uuid() (airflow.models.kubernetes.KubeWorkerIdentifier static method) (airflow.models.KubeWorkerIdentifier static method) get_pandas_df() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method) (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.hooks.base_hook.BaseHook 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_password() (airflow.models.Connection method) (airflow.models.connection.Connection method) get_path() (airflow.contrib.hooks.fs_hook.FSHook method) get_pool() (airflow.models.Pool static method) (airflow.models.pool.Pool static method) get_previous_dagrun() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_previous_scheduled_dagrun() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_product() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) get_product_set() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) get_proxy_version() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) get_query_results() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) (airflow.contrib.hooks.qubole_check_hook.QuboleCheckHook method) get_records() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.hooks.base_hook.BaseHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.hive_hooks.HiveServer2Hook method) (airflow.hooks.presto_hook.PrestoHook method) get_resource_type() (airflow.contrib.hooks.aws_hook.AwsHook method) get_results() (airflow.contrib.hooks.qubole_hook.QuboleHook method) (airflow.contrib.operators.qubole_operator.QuboleOperator method) (airflow.hooks.hive_hooks.HiveServer2Hook method) get_run() (airflow.models.DagRun static method) (airflow.models.dagrun.DagRun static method) get_run_dates() (airflow.models.DAG method) (airflow.models.dag.DAG method) GET_RUN_ENDPOINT (in module airflow.contrib.hooks.databricks_hook) get_run_page_url() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) get_run_state() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) get_s3_key() (airflow.contrib.operators.s3_to_sftp_operator.S3ToSFTPOperator static method) (airflow.contrib.operators.sftp_to_s3_operator.SFTPToS3Operator static method) get_sagemaker_response() (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method) (airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor method) (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor method) (airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor method) (airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor method) get_schema() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) get_service() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method) 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) get_socket_path() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) get_sql_from_qbol_cmd() (in module airflow.contrib.operators.qubole_check_operator) get_sqlalchemy_engine() (airflow.hooks.dbapi_hook.DbApiHook method) get_sqlproxy_runner() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) get_state() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_state_change_reason() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) get_state_exitcode_details() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) get_storagekey() (airflow.contrib.hooks.azure_container_volume_hook.AzureContainerVolumeHook method) get_stored_info_type() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) get_table() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method) (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_table_location() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method) get_tabledata() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) get_tables() (airflow.hooks.hive_hooks.HiveMetastoreHook method) get_task() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_task_instance() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_task_instances() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.operators.BaseOperator method) get_template_context() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_template_env() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) get_time() (in module airflow.contrib.sensors.gcs_sensor) get_transfer_job() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) get_transfer_operation() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook 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.dbapi_hook.DbApiHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) get_val() (airflow.models.Variable method) (airflow.models.variable.Variable method) get_wildcard_key() (airflow.hooks.S3_hook.S3Hook method) GKEClusterCreateOperator (class in airflow.contrib.operators.gcp_container_operator) GKEClusterDeleteOperator (class in airflow.contrib.operators.gcp_container_operator) GKEClusterHook (class in airflow.contrib.hooks.gcp_container_hook) GKEPodOperator (class in airflow.contrib.operators.gcp_container_operator) global_operator_extra_link_dict() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) google_cloud_to_local() (airflow.contrib.operators.dataflow_operator.GoogleCloudBucketHelper method) GoogleCloudBaseHook (class in airflow.contrib.hooks.gcp_api_base_hook) GoogleCloudBaseHook._Decorators (class in airflow.contrib.hooks.gcp_api_base_hook) GoogleCloudBucketHelper (class in airflow.contrib.operators.dataflow_operator) GoogleCloudKMSHook (class in airflow.contrib.hooks.gcp_kms_hook) GoogleCloudStorageBucketCreateAclEntryOperator (class in airflow.contrib.operators.gcs_acl_operator) GoogleCloudStorageCreateBucketOperator (class in airflow.contrib.operators.gcs_operator) GoogleCloudStorageDeleteOperator (class in airflow.contrib.operators.gcs_delete_operator) GoogleCloudStorageDownloadOperator (class in airflow.contrib.operators.gcs_download_operator) GoogleCloudStorageHook (class in airflow.contrib.hooks.gcs_hook) GoogleCloudStorageListOperator (class in airflow.contrib.operators.gcs_list_operator) 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) GoogleCloudStorageToGoogleCloudStorageOperator (class in airflow.contrib.operators.gcs_to_gcs) GoogleCloudStorageToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.gcp_transfer_operator) GoogleCloudStorageToS3Operator (class in airflow.contrib.operators.gcs_to_s3) GoogleCloudStorageUploadSessionCompleteSensor (class in airflow.contrib.sensors.gcs_sensor) GrpcHook (class in airflow.contrib.hooks.grpc_hook)

H

handle_airflow_exception() (in module airflow.contrib.operators.qubole_check_operator) handle_callback() (airflow.models.DAG method) (airflow.models.dag.DAG method) handle_failure() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) handle_failure_retry() (airflow.contrib.hooks.qubole_check_hook.QuboleCheckHook static method) (airflow.contrib.hooks.qubole_hook.QuboleHook static method) has_attachments() (airflow.contrib.hooks.imap_hook.Mail method) has_dag() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) has_equal_name() (airflow.contrib.hooks.imap_hook.MailPart method) has_mail_attachment() (airflow.contrib.hooks.imap_hook.ImapHook method) has_matching_name() (airflow.contrib.hooks.imap_hook.MailPart method) has_task() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) (airflow.models.DAG method) (airflow.models.dag.DAG method) HDFSHook (class in airflow.hooks.hdfs_hook) HDFSHookException HdfsSensor (class in airflow.operators.sensors) (class in airflow.sensors.hdfs_sensor) HdfsSensorFolder (class in airflow.contrib.sensors.hdfs_sensor) HdfsSensorRegex (class in airflow.contrib.sensors.hdfs_sensor) heartbeat() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method)

height (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) 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) HIVE_QUEUE_PRIORITIES (in module airflow.hooks.hive_hooks) 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.operators.sensors) (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) host (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) hostname (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) HOURS (in module airflow.contrib.hooks.gcp_transfer_hook) HTTP_DATA_SOURCE (in module airflow.contrib.hooks.gcp_transfer_hook) HttpHook (class in airflow.hooks.http_hook) HttpSensor (class in airflow.operators.sensors) (class in airflow.sensors.http_sensor)

I

id (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) (airflow.models.knownevent.KnownEventType attribute) (airflow.models.KnownEventType attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.User attribute) (airflow.models.user.User attribute) (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) id_for_date() (airflow.models.DagRun class method) (airflow.models.dagrun.DagRun class method) ID_FORMAT_PREFIX (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) ID_LEN (in module airflow.models) (in module airflow.models.base) ID_PREFIX (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) ImapAttachmentSensor (class in airflow.contrib.sensors.imap_attachment_sensor) ImapAttachmentToS3Operator (class in airflow.contrib.operators.imap_attachment_to_s3_operator) ImapHook (class in airflow.contrib.hooks.imap_hook) import_from_storage_bucket() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) 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) (class in airflow.models.errors) IN_PROGRESS (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferOperationStatus attribute) init_log_resource() (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor method) init_on_load() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.models.XCom method) (airflow.models.xcom.XCom method) init_run_context() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) insert_all() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) insert_bucket_acl() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) insert_documents() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) 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) insert_one() (airflow.contrib.hooks.mongo_hook.MongoHook method) insert_rows() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method) (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.druid_hook.DruidDbApiHook method) (airflow.hooks.oracle_hook.OracleHook method) (airflow.hooks.presto_hook.PrestoHook method)

inspect_content() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) integer_fields (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator attribute) (airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator attribute) (airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator attribute) (airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator attribute) INTERMEDIATE_STATES (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook attribute) (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor attribute) IntervalCheckOperator (class in airflow.operators.check_operator) INVALID_KEYS (in module airflow.contrib.hooks.gcp_api_base_hook) INVALID_REASONS (in module airflow.contrib.hooks.gcp_api_base_hook) InvalidFernetToken INVOKE_ASYNC_FUNCTION (airflow.contrib.hooks.openfaas_hook.OpenFaasHook attribute) invoke_async_function() (airflow.contrib.hooks.openfaas_hook.OpenFaasHook method) invoke_lambda() (airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook method) is_active (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) is_array_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) is_attachment() (airflow.contrib.hooks.imap_hook.MailPart method) is_backfill (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) is_bucket_updated() (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageUploadSessionCompleteSensor method) is_eligible_to_retry() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) is_encrypted (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.crypto.NullFernet attribute) (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) is_extra_encrypted (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) is_fixed_time_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) is_paused (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) is_paused_at_creation (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) is_premature (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) is_record_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) is_simple_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method) is_soft_quota_exception() (in module airflow.contrib.hooks.gcp_api_base_hook) is_subdag (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) is_successful (airflow.contrib.hooks.databricks_hook.RunState attribute) is_superuser() (airflow.models.User method) (airflow.models.user.User method) is_terminal (airflow.contrib.hooks.databricks_hook.RunState attribute) is_updated_after() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) isbool() (in module airflow.contrib.hooks.qubole_check_hook) isfloat() (in module airflow.contrib.hooks.qubole_check_hook) isint() (in module airflow.contrib.hooks.qubole_check_hook) issue_field_checker() (airflow.contrib.sensors.jira_sensor.JiraTicketSensor method) iteration_no (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute)

J

JdbcHook (class in airflow.hooks.jdbc_hook) JdbcOperator (class in airflow.operators.jdbc_operator) jenkins_request_with_headers() (in module airflow.contrib.operators.jenkins_job_trigger_operator) JenkinsHook (class in airflow.contrib.hooks.jenkins_hook) JenkinsJobTriggerOperator (class in airflow.contrib.operators.jenkins_job_trigger_operator) JiraHook (class in airflow.contrib.hooks.jira_hook) JiraOperator (class in airflow.contrib.operators.jira_operator) JiraSensor (class in airflow.contrib.sensors.jira_sensor) JiraTicketSensor (class in airflow.contrib.sensors.jira_sensor)

JOB_COMPLETE (airflow.contrib.hooks.sagemaker_hook.LogState attribute) job_id (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) job_type (airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcHiveOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcJobBaseOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcPigOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcSparkOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator attribute)

K

key (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) kill() (airflow.contrib.hooks.qubole_hook.QuboleHook method) (airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method) (airflow.hooks.hive_hooks.HiveCliHook method) (airflow.hooks.pig_hook.PigCliHook method) kill_zombies() (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) know_event_type (airflow.models.knownevent.KnownEventType attribute) (airflow.models.KnownEventType attribute) known_event_type_id (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute)

KnownEvent (class in airflow.models) (class in airflow.models.knownevent) KnownEventType (class in airflow.models) (class in airflow.models.knownevent) KUBE_CONFIG_ENV_VAR (in module airflow.contrib.operators.gcp_container_operator) KubeConfig (class in airflow.contrib.executors.kubernetes_executor) KubeResourceVersion (class in airflow.models) (class in airflow.models.kubernetes) kubernetes_section (airflow.contrib.executors.kubernetes_executor.KubeConfig attribute) KubernetesExecutor (airflow.executors.Executors attribute) (class in airflow.contrib.executors.kubernetes_executor) KubernetesExecutorConfig (class in airflow.contrib.executors.kubernetes_executor) KubernetesJobWatcher (class in airflow.contrib.executors.kubernetes_executor) KubernetesPodOperator (class in airflow.contrib.operators.kubernetes_pod_operator) KubeWorkerIdentifier (class in airflow.models) (class in airflow.models.kubernetes)

L

label (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) label_detection() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) last_expired (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) last_modified (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) last_pickled (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) last_scheduler_run (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) latest_execution_date (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) LatestOnlyOperator (class in airflow.operators.latest_only_operator) leaves (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) list() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) list_deidentify_templates() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) list_directories_and_files() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) list_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) list_dlp_jobs() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) list_info_types() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) list_inspect_templates() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) list_job_triggers() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) list_keys() (airflow.hooks.S3_hook.S3Hook method) list_prefixes() (airflow.hooks.S3_hook.S3Hook method) list_stored_info_types() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) list_transfer_job() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) list_transfer_operations() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) LIST_URL (in module airflow.contrib.hooks.gcp_transfer_hook) list_versions() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) load_bytes() (airflow.hooks.S3_hook.S3Hook method) LOAD_CHECK_INTERVAL (in module airflow.operators.hive_to_druid)

load_df() (airflow.hooks.hive_hooks.HiveCliHook method) load_file() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) (airflow.contrib.hooks.wasb_hook.WasbHook method) (airflow.hooks.hive_hooks.HiveCliHook method) (airflow.hooks.S3_hook.S3Hook method) (airflow.hooks.webhdfs_hook.WebHDFSHook method) load_file_obj() (airflow.hooks.S3_hook.S3Hook method) load_stream() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) load_string() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) (airflow.contrib.hooks.wasb_hook.WasbHook method) (airflow.hooks.S3_hook.S3Hook method) LocalExecutor (airflow.executors.Executors attribute) (class in airflow.executors) (class in airflow.executors.local_executor) LocalExecutor._LimitedParallelism (class in airflow.executors) (class in airflow.executors.local_executor) LocalExecutor._UnlimitedParallelism (class in airflow.executors) (class in airflow.executors.local_executor) LocalWorker (class in airflow.executors.local_executor) log (airflow.executors.LoggingMixin attribute) Log (class in airflow.models) (class in airflow.models.log) log (in module airflow.contrib.operators.mlengine_operator) (in module airflow.hooks.webhdfs_hook) log_filepath (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) log_stream() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) log_url (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) logger (airflow.executors.LoggingMixin attribute) (in module airflow.contrib.hooks.gcp_api_base_hook) LoggingMixin (class in airflow.executors) login (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) LogState (class in airflow.contrib.hooks.sagemaker_hook) lookup() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)

M

Mail (class in airflow.contrib.hooks.imap_hook) MailPart (class in airflow.contrib.hooks.imap_hook) make_query() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) mark_success_url (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) MAX_LABEL_LEN (in module airflow.contrib.executors.kubernetes_executor) MAX_PART_COUNT (airflow.hooks.hive_hooks.HiveMetastoreHook attribute) max_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method) (in module airflow.macros.hive) MAX_POD_ID_LEN (in module airflow.contrib.executors.kubernetes_executor) max_tries (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) MAX_XCOM_SIZE (in module airflow.models.xcom) MesosExecutor (airflow.executors.Executors attribute) (class in airflow.contrib.executors.mesos_executor) METADATA (in module airflow.contrib.hooks.gcp_transfer_hook) metadata (in module airflow.models.base) MetastorePartitionSensor (class in airflow.operators.sensors) (class in airflow.sensors.metastore_partition_sensor)

MINUTES (in module airflow.contrib.hooks.gcp_transfer_hook) MLEngineBatchPredictionOperator (class in airflow.contrib.operators.mlengine_operator) MLEngineHook (class in airflow.contrib.hooks.gcp_mlengine_hook) MLEngineModelOperator (class in airflow.contrib.operators.mlengine_operator) MLEngineTrainingOperator (class in airflow.contrib.operators.mlengine_operator) MLEngineVersionOperator (class in airflow.contrib.operators.mlengine_operator) mlsd() (in module airflow.contrib.hooks.ftp_hook) MongoHook (class in airflow.contrib.hooks.mongo_hook) MongoSensor (class in airflow.contrib.sensors.mongo_sensor) MongoToS3Operator (class in airflow.contrib.operators.mongo_to_s3) MONTH (in module airflow.contrib.hooks.gcp_transfer_hook) MsSqlHook (class in airflow.hooks.mssql_hook) MsSqlOperator (class in airflow.operators.mssql_operator) MsSqlToGoogleCloudStorageOperator (class in airflow.contrib.operators.mssql_to_gcs) MsSqlToHiveTransfer (class in airflow.operators.mssql_to_hive) multi_stream_iter() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) MySqlHook (class in airflow.hooks.mysql_hook) MySqlOperator (class in airflow.operators.mysql_operator) MySqlToGoogleCloudStorageOperator (class in airflow.contrib.operators.mysql_to_gcs) MySqlToHiveTransfer (class in airflow.operators.mysql_to_hive)

N

name (airflow.contrib.operators.bigquery_operator.BigQueryConsoleLink attribute) (airflow.contrib.operators.qubole_operator.QDSLink attribute) (airflow.models.baseoperator.BaseOperatorLink attribute) NAME (in module airflow.contrib.hooks.gcp_transfer_hook) NameDeterminer (class in airflow.contrib.hooks.gcp_vision_hook) NamedHivePartitionSensor (class in airflow.sensors.named_hive_partition_sensor) NEGATIVE_STATUSES (in module airflow.contrib.hooks.gcp_transfer_hook) next() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) next_retry_datetime() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) next_try_number (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) non_terminal_states (airflow.contrib.hooks.sagemaker_hook.SageMakerHook attribute)

NON_TERMINAL_STATES (airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor attribute) (airflow.contrib.sensors.emr_step_sensor.EmrStepSensor attribute) non_terminal_states() (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method) (airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor method) (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor method) (airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor method) (airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor method) normalize_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) NoteBook (class in airflow.operators.papermill_operator) notification_sent (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) NullFernet (class in airflow.models.crypto) num_retries (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook attribute)

O

OBJECT_CONDITIONS (in module airflow.contrib.hooks.gcp_transfer_hook) occupied_slots() (airflow.models.Pool method) (airflow.models.pool.Pool method) offerRescinded() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) OK_STATUS_CODE (in module airflow.contrib.hooks.openfaas_hook) on_error() (airflow.contrib.hooks.segment_hook.SegmentHook method) on_kill() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method) (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator method) (airflow.contrib.operators.azure_container_instances_operator.AzureContainerInstancesOperator method) (airflow.contrib.operators.bigquery_operator.BigQueryOperator method) (airflow.contrib.operators.databricks_operator.DatabricksRunNowOperator method) (airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator method) (airflow.contrib.operators.dataproc_operator.DataProcJobBaseOperator method) (airflow.contrib.operators.ecs_operator.ECSOperator method) (airflow.contrib.operators.qubole_operator.QuboleOperator 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.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) (airflow.operators.bash_operator.BashOperator method) (airflow.operators.docker_operator.DockerOperator method) (airflow.operators.hive_operator.HiveOperator method) (airflow.operators.pig_operator.PigOperator method) one_row_id (airflow.models.KubeResourceVersion attribute) (airflow.models.kubernetes.KubeResourceVersion attribute) (airflow.models.kubernetes.KubeWorkerIdentifier attribute) (airflow.models.KubeWorkerIdentifier attribute) open_slots() (airflow.models.Pool method) (airflow.models.pool.Pool method)

OpenFaasHook (class in airflow.contrib.hooks.openfaas_hook) OPERATIONAL_POLL_INTERVAL (in module airflow.contrib.hooks.gcp_container_hook) OPERATIONS (in module airflow.contrib.hooks.gcp_transfer_hook) operations_contain_expected_statuses() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook static method) operator (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) operator_extra_link_dict() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) operator_extra_links (airflow.contrib.operators.bigquery_operator.BigQueryOperator attribute) (airflow.contrib.operators.qubole_operator.QuboleOperator attribute) (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) operators (airflow.models.baseoperator.BaseOperatorLink attribute) OpsgenieAlertHook (class in airflow.contrib.hooks.opsgenie_alert_hook) OpsgenieAlertOperator (class in airflow.contrib.operators.opsgenie_alert_operator) OracleHook (class in airflow.hooks.oracle_hook) OracleOperator (class in airflow.operators.oracle_operator) OracleToAzureDataLakeTransfer (class in airflow.contrib.operators.oracle_to_azure_data_lake_transfer) OracleToOracleTransfer (class in airflow.contrib.operators.oracle_to_oracle_transfer) overwrite_params_with_dag_run_conf() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) owner (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) owners (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute)

P

PapermillOperator (class in airflow.operators.papermill_operator) PARALLELISM (in module airflow.executors.base_executor) parse_config_integers() (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator method) parse_first_row() (in module airflow.contrib.hooks.qubole_check_hook) parse_from_uri() (airflow.models.Connection method) (airflow.models.connection.Connection method) parse_integer() (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator method) parse_netloc_to_hostname() (in module airflow.models.connection) parse_partition_name() (airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor static method) parse_s3_url() (airflow.hooks.S3_hook.S3Hook static method) parser (in module airflow.contrib.hooks.spark_jdbc_script) password (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) patch_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) patch_dataset() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) patch_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method) patch_instance_group_manager() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) patch_table() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) pause_transfer_operation() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) PAUSED (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferOperationStatus attribute) PENDING (airflow.contrib.hooks.gcp_compute_hook.GceOperationStatus attribute) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlOperationStatus attribute) pickle (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) pickle() (airflow.models.DAG method) (airflow.models.dag.DAG method) pickle_hash (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) pickle_id (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) pickle_info() (airflow.models.DAG method) (airflow.models.dag.DAG method) pid (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) 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.operators.gcp_bigtable_operator.BigtableTableWaitForReplicationSensor method) (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) (airflow.contrib.sensors.aws_sqs_sensor.SQSSensor method) (airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor method) (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.gcp_transfer_sensor.GCPTransferServiceWaitForJobStatusSensor 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.gcs_sensor.GoogleCloudStorageUploadSessionCompleteSensor method) (airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder method) (airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex method) (airflow.contrib.sensors.imap_attachment_sensor.ImapAttachmentSensor method) (airflow.contrib.sensors.jira_sensor.JiraSensor method) (airflow.contrib.sensors.jira_sensor.JiraTicketSensor method) (airflow.contrib.sensors.mongo_sensor.MongoSensor 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.redis_pub_sub_sensor.RedisPubSubSensor method) (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method) (airflow.contrib.sensors.sftp_sensor.SFTPSensor method) (airflow.contrib.sensors.wasb_sensor.WasbBlobSensor method) (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) poke_partition() (airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor method) poll_job_complete() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method)

poll_job_in_queue() (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method) poll_operation_until_done() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) poll_query_status() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) pool (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) Pool (class in airflow.models) (class in airflow.models.pool) pool_full() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) Popen() (airflow.contrib.hooks.sqoop_hook.SqoopHook method) port (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) Position (in module airflow.contrib.hooks.sagemaker_hook) POSITIONAL_ARGS (in module airflow.contrib.hooks.qubole_hook) post_event() (airflow.contrib.hooks.datadog_hook.DatadogHook method) post_execute() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) 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) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) prepare_additional_parameters() (in module airflow.contrib.operators.gcp_vision_operator) prepare_request() (airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method) (airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator method) prepare_template() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) (airflow.operators.hive_operator.HiveOperator method) (airflow.operators.pig_operator.PigOperator method) preprocess_body() (airflow.contrib.operators.gcp_function_operator.ZipPathPreprocessor method) preprocess_config() (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator method) PrestoCheckOperator (class in airflow.operators.presto_check_operator) PrestoException 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_execution_date_success (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) previous_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) previous_start_date_success (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) previous_ti (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) previous_ti_success (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) priority_weight (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) priority_weight_total (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) process_body() (airflow.contrib.operators.gcp_cloud_build_operator.BuildProcessor method) (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor method) process_error() (airflow.contrib.executors.kubernetes_executor.KubernetesJobWatcher method) process_file() (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) process_status() (airflow.contrib.executors.kubernetes_executor.KubernetesJobWatcher method) process_watcher_task() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) product_name_determiner (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook attribute) product_set_name_determiner (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook attribute) project_id (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook attribute) PROJECT_ID (in module airflow.contrib.hooks.gcp_transfer_hook) provide_gcp_credential_file() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook._Decorators static method) publish() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method) publish_to_target() (airflow.contrib.hooks.aws_sns_hook.AwsSnsHook method) PubSubException 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) push_from_local() (airflow.hooks.samba_hook.SambaHook method) PUT (airflow.contrib.operators.sftp_operator.SFTPOperation attribute) put_records() (airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method) PY3 (in module airflow.contrib.operators.mysql_to_gcs) (in module airflow.contrib.operators.postgres_to_gcs_operator) (in module airflow.contrib.operators.sql_to_gcs) PythonOperator (class in airflow.operators.python_operator) PythonSensor (class in airflow.contrib.sensors.python_sensor) PythonVirtualenvOperator (class in airflow.operators.python_operator)

Q

QDSLink (class in airflow.contrib.operators.qubole_operator) qubole_hook_allowed_args_list (airflow.contrib.operators.qubole_operator.QuboleOperator attribute) QuboleCheckHook (class in airflow.contrib.hooks.qubole_check_hook) QuboleCheckOperator (class in airflow.contrib.operators.qubole_check_operator) QuboleFileSensor (class in airflow.contrib.sensors.qubole_sensor) QuboleHook (class in airflow.contrib.hooks.qubole_hook) QuboleOperator (class in airflow.contrib.operators.qubole_operator) 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) query() (airflow.contrib.operators.mssql_to_gcs.MsSqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator method) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator method)

query_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method) queue (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) queue_command() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) queue_task_instance() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) queued_dttm (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) queued_slots() (airflow.models.Pool method) (airflow.models.pool.Pool method) QueuedLocalWorker (class in airflow.executors.local_executor) quota_retry() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook static method)

R

raise_error() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJob method) random() (in module airflow.macros) ratio_formulas (airflow.operators.check_operator.IntervalCheckOperator attribute) read_file() (airflow.contrib.hooks.wasb_hook.WasbHook method) read_key() (airflow.hooks.S3_hook.S3Hook method) ready_for_retry() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) recognize_speech() (airflow.contrib.hooks.gcp_speech_to_text_hook.GCPSpeechToTextHook method) record_exists() (airflow.contrib.hooks.cassandra_hook.CassandraHook method) redact_image() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) RedisHook (class in airflow.contrib.hooks.redis_hook) RedisKeySensor (class in airflow.contrib.sensors.redis_key_sensor) RedisPublishOperator (class in airflow.contrib.operators.redis_publish_operator) RedisPubSubSensor (class in airflow.contrib.sensors.redis_pub_sub_sensor) RedshiftHook (class in airflow.contrib.hooks.redshift_hook) RedshiftToS3Transfer (class in airflow.operators.redshift_to_s3_operator) refresh_from_db() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) REGEX_REPO_PATH (in module airflow.contrib.operators.gcp_cloud_build_operator) registered() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) reidentify_content() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) remove_product_from_product_set() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) rename() (airflow.contrib.hooks.ftp_hook.FTPHook method) render_template() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) render_template_fields() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) render_templates() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) replace_many() (airflow.contrib.hooks.mongo_hook.MongoHook method) replace_one() (airflow.contrib.hooks.mongo_hook.MongoHook method) reported_by (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) REQUIRED_ATTRIBUTES (airflow.contrib.operators.gcp_bigtable_operator.BigtableClusterUpdateOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceCreateOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceDeleteOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableCreateOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableDeleteOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableWaitForReplicationSensor attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableValidationMixin attribute) reregistered() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) reschedule (airflow.sensors.base_sensor_operator.BaseSensorOperator attribute) reschedule_date (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) reserve_free_tcp_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) reset_resource_version() (airflow.models.KubeResourceVersion static method) (airflow.models.kubernetes.KubeResourceVersion static method) resolve_template_files() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.BaseOperator method) resource_version (airflow.models.KubeResourceVersion attribute) (airflow.models.kubernetes.KubeResourceVersion attribute) resourceOffers() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method)

restart_cluster() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) RESTART_CLUSTER_ENDPOINT (in module airflow.contrib.hooks.databricks_hook) restore_from_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method) resume_transfer_operation() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) 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) retry_if_temporary_quota (class in airflow.contrib.hooks.gcp_api_base_hook) rewrite() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) rollback() (airflow.contrib.hooks.bigquery_hook.BigQueryConnection method) (airflow.contrib.hooks.datastore_hook.DatastoreHook method) roots (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) rotate_fernet_key() (airflow.models.Connection method) (airflow.models.connection.Connection method) (airflow.models.Variable method) (airflow.models.variable.Variable method) ROW_DELIM (in module airflow.contrib.hooks.qubole_check_hook) rowcount (airflow.contrib.hooks.bigquery_hook.BigQueryCursor attribute) run() (airflow.contrib.executors.kubernetes_executor.KubernetesJobWatcher method) (airflow.contrib.hooks.grpc_hook.GrpcHook method) (airflow.executors.local_executor.LocalWorker method) (airflow.executors.local_executor.QueuedLocalWorker method) (airflow.hooks.base_hook.BaseHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.http_hook.HttpHook method) (airflow.hooks.presto_hook.PrestoHook method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.operators.BaseOperator 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_copy() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) run_extract() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) run_grant_dataset_view_access() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) run_id (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) RUN_LIFE_CYCLE_STATES (in module airflow.contrib.hooks.databricks_hook) run_load() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) run_next() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) run_now() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) RUN_NOW_ENDPOINT (in module airflow.contrib.hooks.databricks_hook) run_query() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method) (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) (airflow.contrib.hooks.datastore_hook.DatastoreHook method) (airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method) run_table_delete() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) run_table_upsert() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) run_with_advanced_retry() (airflow.hooks.http_hook.HttpHook method) run_with_configuration() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) RUNNING (airflow.contrib.hooks.gcp_compute_hook.GceOperationStatus attribute) (airflow.contrib.hooks.gcp_sql_hook.CloudSqlOperationStatus attribute) RunState (class in airflow.contrib.hooks.databricks_hook)

S

S3CopyObjectOperator (class in airflow.contrib.operators.s3_copy_object_operator) S3DeleteObjectsOperator (class in airflow.contrib.operators.s3_delete_objects_operator) S3FileTransformOperator (class in airflow.operators.s3_file_transform_operator) S3Hook (class in airflow.hooks.S3_hook) S3KeySensor (class in airflow.operators.sensors) (class in airflow.sensors.s3_key_sensor) S3ListOperator (class in airflow.contrib.operators.s3_list_operator) S3PrefixSensor (class in airflow.operators.sensors) (class in airflow.sensors.s3_prefix_sensor) S3ToGoogleCloudStorageOperator (class in airflow.contrib.operators.s3_to_gcs_operator) S3ToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.gcp_transfer_operator) S3ToHiveTransfer (class in airflow.operators.s3_to_hive_operator) S3ToRedshiftTransfer (class in airflow.operators.s3_to_redshift_operator) S3ToSFTPOperator (class in airflow.contrib.operators.s3_to_sftp_operator) safe_dag_id (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) safe_search_detection() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) 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) SageMakerEndpointOperator (class in airflow.contrib.operators.sagemaker_endpoint_operator) SageMakerEndpointSensor (class in airflow.contrib.sensors.sagemaker_endpoint_sensor) SageMakerHook (class in airflow.contrib.hooks.sagemaker_hook) SageMakerModelOperator (class in airflow.contrib.operators.sagemaker_model_operator) SageMakerTrainingOperator (class in airflow.contrib.operators.sagemaker_training_operator) SageMakerTrainingSensor (class in airflow.contrib.sensors.sagemaker_training_sensor) SageMakerTransformOperator (class in airflow.contrib.operators.sagemaker_transform_operator) SageMakerTransformSensor (class in airflow.contrib.sensors.sagemaker_transform_sensor) SageMakerTuningOperator (class in airflow.contrib.operators.sagemaker_tuning_operator) SageMakerTuningSensor (class in airflow.contrib.sensors.sagemaker_tuning_sensor) SalesforceHook (class in airflow.contrib.hooks.salesforce_hook) SambaHook (class in airflow.hooks.samba_hook) sanitize_queries() (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseQueryOperator static method) SCHEDULE (in module airflow.contrib.hooks.gcp_transfer_hook) SCHEDULE_END_DATE (in module airflow.contrib.hooks.gcp_transfer_hook) schedule_interval (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) (airflow.operators.BaseOperator attribute) SCHEDULE_START_DATE (in module airflow.contrib.hooks.gcp_transfer_hook) ScheduleInterval (in module airflow.models.dag) scheduler_lock (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) SCHEDULER_ZOMBIE_TASK_THRESHOLD (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) schema (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) secondary_training_status_changed() (in module airflow.contrib.hooks.sagemaker_hook) secondary_training_status_message() (in module airflow.contrib.hooks.sagemaker_hook) SECONDS (in module airflow.contrib.hooks.gcp_transfer_hook) SECRET_ACCESS_KEY (in module airflow.contrib.hooks.gcp_transfer_hook) SegmentHook (class in airflow.contrib.hooks.segment_hook) SegmentTrackEventOperator (class in airflow.contrib.operators.segment_track_event_operator) select_key() (airflow.hooks.S3_hook.S3Hook method) send() (airflow.contrib.hooks.dingding_hook.DingdingHook method) send_message() (airflow.contrib.hooks.aws_sqs_hook.SQSHook method) send_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method) send_task_to_executor() (in module airflow.executors.celery_executor) SequentialExecutor (airflow.executors.Executors attribute) (class in airflow.executors) (class in airflow.executors.sequential_executor) serialize_value() (airflow.models.XCom static method) (airflow.models.xcom.XCom static method) set() (airflow.models.Variable class method) (airflow.models.variable.Variable class method) (airflow.models.XCom class method) (airflow.models.xcom.XCom class method) set_arraysize() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor 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.jdbc_hook.JdbcHook method) (airflow.hooks.mssql_hook.MsSqlHook method) (airflow.hooks.mysql_hook.MySqlHook method) set_common_options() (in module airflow.contrib.hooks.spark_jdbc_script) set_dag_runs_state() (airflow.models.DAG method) (airflow.models.dag.DAG method) set_default_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) set_dependency() (airflow.models.DAG method) (airflow.models.dag.DAG method) set_downstream() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) set_duration() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) set_extra() (airflow.models.Connection method) (airflow.models.connection.Connection method) set_is_paused() (airflow.models.dag.DagModel method) (airflow.models.DagModel method) set_job_name() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) set_machine_type() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) SET_MACHINE_TYPE_VALIDATION_SPECIFICATION (in module airflow.contrib.operators.gcp_compute_operator) set_main() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) set_password() (airflow.models.Connection method) (airflow.models.connection.Connection method) set_python_main() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJobBuilder method) set_state() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) set_upstream() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.BaseOperator method) set_val() (airflow.models.Variable method) (airflow.models.variable.Variable method) setdefault() (airflow.models.Variable class method) (airflow.models.variable.Variable class method) setinputsizes() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) setoutputsize() (airflow.contrib.hooks.bigquery_hook.BigQueryCursor method) SETTINGS (in module airflow.contrib.operators.gcp_sql_operator) SETTINGS_VERSION (in module airflow.contrib.operators.gcp_sql_operator) SFTPHook (class in airflow.contrib.hooks.sftp_hook) SFTPOperation (class in airflow.contrib.operators.sftp_operator) SFTPOperator (class in airflow.contrib.operators.sftp_operator) SFTPSensor (class in airflow.contrib.sensors.sftp_sensor) SFTPToS3Operator (class in airflow.contrib.operators.sftp_to_s3_operator) shallow_copy_attrs (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) (airflow.operators.python_operator.PythonOperator attribute) ShortCircuitOperator (class in airflow.operators.python_operator) should_upload_function() (airflow.contrib.operators.gcp_function_operator.ZipPathPreprocessor method) show_datatable (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) show_sql (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) 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) (airflow.models.dagbag.DagBag method) skip() (airflow.models.SkipMixin method) (airflow.models.skipmixin.SkipMixin method) skip_all_except() (airflow.models.SkipMixin method) (airflow.models.skipmixin.SkipMixin method) SkipMixin (class in airflow.models) (class in airflow.models.skipmixin) 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) (class in airflow.models.slamiss) slaveLost() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) slots (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) snakebite_loaded (in module airflow.hooks.hdfs_hook) SnowflakeHook (class in airflow.contrib.hooks.snowflake_hook) SnowflakeOperator (class in airflow.contrib.operators.snowflake_operator) SnsPublishOperator (class in airflow.contrib.operators.sns_publish_operator) SOURCE_REPOSITORY (in module airflow.contrib.operators.gcp_function_operator) spark_read_from_jdbc() (in module airflow.contrib.hooks.spark_jdbc_script) spark_write_to_jdbc() (in module airflow.contrib.hooks.spark_jdbc_script) 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) sql (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) SQL_ALCHEMY_SCHEMA (in module airflow.models.base) sql_layout (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) SqliteHook (class in airflow.hooks.sqlite_hook) SqliteOperator (class in airflow.operators.sqlite_operator) SqlSensor (class in airflow.operators.sensors) (class in airflow.sensors.sql_sensor) SqoopHook (class in airflow.contrib.hooks.sqoop_hook) SqoopOperator (class in airflow.contrib.operators.sqoop_operator) SQSHook (class in airflow.contrib.hooks.aws_sqs_hook) SQSPublishOperator (class in airflow.contrib.operators.aws_sqs_publish_operator) SQSSensor (class in airflow.contrib.sensors.aws_sqs_sensor) SSHHook (class in airflow.contrib.hooks.ssh_hook) SSHOperator (class in airflow.contrib.operators.ssh_operator) stacktrace (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) start() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) (airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator method) (airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator method) (airflow.contrib.operators.dataproc_operator.DataprocOperationBaseOperator method) (airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateInlineOperator method) (airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateOperator method) (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor._LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor._UnlimitedParallelism method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) start_cluster() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) START_CLUSTER_ENDPOINT (in module airflow.contrib.hooks.databricks_hook) start_date (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) start_instance() (airflow.contrib.hooks.gcp_compute_hook.GceHook method) start_java_dataflow() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method) start_proxy() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) start_python_dataflow() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method) start_template_dataflow() (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method) START_TIME_OF_DAY (in module airflow.contrib.hooks.gcp_transfer_hook) STARTING (airflow.contrib.hooks.sagemaker_hook.LogState attribute) state (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) state_from_response() (airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor static method) (airflow.contrib.sensors.emr_step_sensor.EmrStepSensor static method) (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method) (airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor method) (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor method) (airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor method) (airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor method) STATUS (in module airflow.contrib.hooks.gcp_transfer_hook) STATUS1 (in module airflow.contrib.hooks.gcp_transfer_hook) status_code (airflow.executors.AirflowException attribute) statusUpdate() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler 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) (airflow.models.dag.DAG method) SubDagOperator (class in airflow.operators.subdag_operator) subdags (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) submit() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method) submit_indexing_job() (airflow.hooks.druid_hook.DruidHook method) submit_jdbc_job() (airflow.contrib.hooks.spark_jdbc_hook.SparkJDBCHook method) submit_run() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) SUBMIT_RUN_ENDPOINT (in module airflow.contrib.hooks.databricks_hook) SUCCESS (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferOperationStatus attribute) success() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) SUCCESS_STATES (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook attribute) (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor attribute) superuser (airflow.models.User attribute) (airflow.models.user.User attribute) supports_autocommit (airflow.contrib.hooks.pinot_hook.PinotDbApiHook attribute) (airflow.contrib.hooks.snowflake_hook.SnowflakeHook attribute) (airflow.contrib.hooks.vertica_hook.VerticaHook attribute) (airflow.hooks.dbapi_hook.DbApiHook attribute) (airflow.hooks.druid_hook.DruidDbApiHook attribute) (airflow.hooks.jdbc_hook.JdbcHook attribute) (airflow.hooks.mssql_hook.MsSqlHook attribute) (airflow.hooks.mysql_hook.MySqlHook attribute) (airflow.hooks.oracle_hook.OracleHook attribute) (airflow.hooks.postgres_hook.PostgresHook attribute) (airflow.hooks.sqlite_hook.SqliteHook attribute) sync() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor._LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor._UnlimitedParallelism method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) (airflow.executors.sequential_executor.SequentialExecutor method) (airflow.executors.SequentialExecutor method) sync_to_db() (airflow.models.DAG method) (airflow.models.dag.DAG method) synthesize_speech() (airflow.contrib.hooks.gcp_text_to_speech_hook.GCPTextToSpeechHook method)

T

table_exists() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method) (airflow.contrib.hooks.cassandra_hook.CassandraHook method) (airflow.hooks.hive_hooks.HiveMetastoreHook method) TAILING (airflow.contrib.hooks.sagemaker_hook.LogState attribute) tar_and_s3_upload() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) task_id (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) task_ids (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) task_type (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) TaskFail (class in airflow.models) (class in airflow.models.taskfail) TaskInstance (class in airflow.models) (class in airflow.models.taskinstance) TaskReschedule (class in airflow.models) (class in airflow.models.taskreschedule) tasks (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) template_ext (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator attribute) (airflow.contrib.operators.bigquery_check_operator.BigQueryCheckOperator attribute) (airflow.contrib.operators.bigquery_check_operator.BigQueryValueCheckOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryOperator attribute) (airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator attribute) (airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator attribute) (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcHiveOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcPigOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator attribute) (airflow.contrib.operators.druid_operator.DruidOperator attribute) (airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator attribute) (airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator attribute) (airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeployOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseQueryOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseUpdateOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlQueryOperator attribute) (airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator attribute) (airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBTransferOperator attribute) (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator attribute) (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator attribute) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator attribute) (airflow.contrib.operators.qubole_operator.QuboleOperator attribute) (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator attribute) (airflow.contrib.operators.snowflake_operator.SnowflakeOperator attribute) (airflow.contrib.operators.sns_publish_operator.SnsPublishOperator attribute) (airflow.contrib.operators.spark_sql_operator.SparkSqlOperator attribute) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.ssh_operator.SSHOperator attribute) (airflow.contrib.operators.vertica_operator.VerticaOperator attribute) (airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer attribute) (airflow.contrib.operators.vertica_to_mysql.VerticaToMySqlTransfer attribute) (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor attribute) (airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor attribute) (airflow.contrib.sensors.emr_step_sensor.EmrStepSensor attribute) (airflow.contrib.sensors.qubole_sensor.QuboleSensor attribute) (airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor attribute) (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor attribute) (airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor attribute) (airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor attribute) (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) (airflow.operators.bash_operator.BashOperator attribute) (airflow.operators.check_operator.CheckOperator attribute) (airflow.operators.check_operator.IntervalCheckOperator attribute) (airflow.operators.check_operator.ValueCheckOperator attribute) (airflow.operators.docker_operator.DockerOperator attribute) (airflow.operators.email_operator.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.hive_operator.HiveOperator attribute) (airflow.operators.hive_to_druid.HiveToDruidTransfer attribute) (airflow.operators.hive_to_mysql.HiveToMySqlTransfer attribute) (airflow.operators.hive_to_samba_operator.Hive2SambaOperator attribute) (airflow.operators.http_operator.SimpleHttpOperator attribute) (airflow.operators.jdbc_operator.JdbcOperator attribute) (airflow.operators.mssql_operator.MsSqlOperator attribute) (airflow.operators.mssql_to_hive.MsSqlToHiveTransfer attribute) (airflow.operators.mysql_operator.MySqlOperator attribute) (airflow.operators.mysql_to_hive.MySqlToHiveTransfer attribute) (airflow.operators.oracle_operator.OracleOperator attribute) (airflow.operators.pig_operator.PigOperator attribute) (airflow.operators.postgres_operator.PostgresOperator attribute) (airflow.operators.presto_to_mysql.PrestoToMySqlTransfer attribute) (airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer attribute) (airflow.operators.s3_file_transform_operator.S3FileTransformOperator attribute) (airflow.operators.s3_to_hive_operator.S3ToHiveTransfer attribute) (airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer attribute) (airflow.operators.sqlite_operator.SqliteOperator attribute) (airflow.sensors.sql_sensor.SqlSensor attribute) template_fields (airflow.contrib.operators.adls_list_operator.AzureDataLakeStorageListOperator attribute) (airflow.contrib.operators.adls_to_gcs.AdlsToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator attribute) (airflow.contrib.operators.aws_sqs_publish_operator.SQSPublishOperator attribute) (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator attribute) (airflow.contrib.operators.azure_container_instances_operator.AzureContainerInstancesOperator attribute) (airflow.contrib.operators.azure_cosmos_operator.AzureCosmosInsertDocumentOperator attribute) (airflow.contrib.operators.bigquery_check_operator.BigQueryCheckOperator attribute) (airflow.contrib.operators.bigquery_check_operator.BigQueryIntervalCheckOperator attribute) (airflow.contrib.operators.bigquery_check_operator.BigQueryValueCheckOperator attribute) (airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryGetDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryPatchDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryUpdateDatasetOperator attribute) (airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator attribute) (airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator attribute) (airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator attribute) (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.databricks_operator.DatabricksRunNowOperator attribute) (airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator attribute) (airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator attribute) (airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator attribute) (airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator attribute) (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator attribute) (airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator attribute) (airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcHiveOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcPigOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcSparkOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator attribute) (airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateInlineOperator attribute) (airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateOperator attribute) (airflow.contrib.operators.dingding_operator.DingdingOperator attribute) (airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator attribute) (airflow.contrib.operators.druid_operator.DruidOperator attribute) (airflow.contrib.operators.ecs_operator.ECSOperator attribute) (airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator attribute) (airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator attribute) (airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator attribute) (airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.file_to_wasb.FileToWasbOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableClusterUpdateOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceCreateOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableInstanceDeleteOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableCreateOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableDeleteOperator attribute) (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableWaitForReplicationSensor attribute) (airflow.contrib.operators.gcp_cloud_build_operator.CloudBuildCreateBuildOperator attribute) (airflow.contrib.operators.gcp_compute_operator.GceInstanceGroupManagerUpdateTemplateOperator attribute) (airflow.contrib.operators.gcp_compute_operator.GceInstanceStartOperator attribute) (airflow.contrib.operators.gcp_compute_operator.GceInstanceStopOperator attribute) (airflow.contrib.operators.gcp_compute_operator.GceInstanceTemplateCopyOperator attribute) (airflow.contrib.operators.gcp_compute_operator.GceSetMachineTypeOperator attribute) (airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator attribute) (airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator attribute) (airflow.contrib.operators.gcp_container_operator.GKEPodOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCancelDLPJobOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateDeidentifyTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateDLPJobOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateInspectTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateJobTriggerOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPCreateStoredInfoTypeOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeidentifyContentOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteDeidentifyTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteDlpJobOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteInspectTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteJobTriggerOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPDeleteStoredInfoTypeOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetDeidentifyTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetDlpJobOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetInspectTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetJobTripperOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPGetStoredInfoTypeOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPInspectContentOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListDeidentifyTemplatesOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListDlpJobsOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListInfoTypesOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListInspectTemplatesOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListJobTriggersOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPListStoredInfoTypesOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPRedactImageOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPReidentifyContentOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateDeidentifyTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateInspectTemplateOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateJobTriggerOperator attribute) (airflow.contrib.operators.gcp_dlp_operator.CloudDLPUpdateStoredInfoTypeOperator attribute) (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeleteOperator attribute) (airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator attribute) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageAnalyzeEntitiesOperator attribute) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageAnalyzeEntitySentimentOperator attribute) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageAnalyzeSentimentOperator attribute) (airflow.contrib.operators.gcp_natural_language_operator.CloudLanguageClassifyTextOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeleteOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseDeployOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseQueryOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDatabaseUpdateOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeleteOperator attribute) (airflow.contrib.operators.gcp_spanner_operator.CloudSpannerInstanceDeployOperator attribute) (airflow.contrib.operators.gcp_speech_to_text_operator.GcpSpeechToTextRecognizeSpeechOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseDeleteOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDeleteOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceExportOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceImportOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlInstancePatchOperator attribute) (airflow.contrib.operators.gcp_sql_operator.CloudSqlQueryOperator attribute) (airflow.contrib.operators.gcp_text_to_speech_operator.GcpTextToSpeechSynthesizeOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobCreateOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobDeleteOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceJobUpdateOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationCancelOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationGetOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationPauseOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationResumeOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GcpTransferServiceOperationsListOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GoogleCloudStorageToGoogleCloudStorageTransferOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.S3ToGoogleCloudStorageTransferOperator attribute) (airflow.contrib.operators.gcp_translate_operator.CloudTranslateTextOperator attribute) (airflow.contrib.operators.gcp_translate_speech_operator.GcpTranslateSpeechOperator attribute) (airflow.contrib.operators.gcp_video_intelligence_operator.CloudVideoIntelligenceDetectVideoExplicitContentOperator attribute) (airflow.contrib.operators.gcp_video_intelligence_operator.CloudVideoIntelligenceDetectVideoLabelsOperator attribute) (airflow.contrib.operators.gcp_video_intelligence_operator.CloudVideoIntelligenceDetectVideoShotsOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionAddProductToProductSetOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionAnnotateImageOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectDocumentTextOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectImageLabelsOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectImageSafeSearchOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionDetectTextOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductCreateOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductDeleteOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductGetOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetCreateOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetDeleteOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetGetOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductSetUpdateOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionProductUpdateOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionReferenceImageCreateOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionRemoveProductFromProductSetOperator attribute) (airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageBucketCreateAclEntryOperator attribute) (airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageObjectCreateAclEntryOperator attribute) (airflow.contrib.operators.gcs_delete_operator.GoogleCloudStorageDeleteOperator attribute) (airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator attribute) (airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator attribute) (airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator attribute) (airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator attribute) (airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.gcs_to_s3.GoogleCloudStorageToS3Operator attribute) (airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator attribute) (airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBTransferOperator attribute) (airflow.contrib.operators.imap_attachment_to_s3_operator.ImapAttachmentToS3Operator attribute) (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator attribute) (airflow.contrib.operators.jira_operator.JiraOperator attribute) (airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator attribute) (airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator attribute) (airflow.contrib.operators.mlengine_operator.MLEngineModelOperator attribute) (airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator attribute) (airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator attribute) (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator attribute) (airflow.contrib.operators.opsgenie_alert_operator.OpsgenieAlertOperator attribute) (airflow.contrib.operators.oracle_to_azure_data_lake_transfer.OracleToAzureDataLakeTransfer attribute) (airflow.contrib.operators.oracle_to_oracle_transfer.OracleToOracleTransfer attribute) (airflow.contrib.operators.pubsub_operator.PubSubPublishOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubSubscriptionCreateOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubSubscriptionDeleteOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubTopicCreateOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubTopicDeleteOperator attribute) (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator attribute) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator attribute) (airflow.contrib.operators.qubole_operator.QuboleOperator attribute) (airflow.contrib.operators.redis_publish_operator.RedisPublishOperator attribute) (airflow.contrib.operators.s3_copy_object_operator.S3CopyObjectOperator attribute) (airflow.contrib.operators.s3_delete_objects_operator.S3DeleteObjectsOperator attribute) (airflow.contrib.operators.s3_list_operator.S3ListOperator attribute) (airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.s3_to_sftp_operator.S3ToSFTPOperator attribute) (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator attribute) (airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator attribute) (airflow.contrib.operators.sftp_operator.SFTPOperator attribute) (airflow.contrib.operators.sftp_to_s3_operator.SFTPToS3Operator attribute) (airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator attribute) (airflow.contrib.operators.snowflake_operator.SnowflakeOperator attribute) (airflow.contrib.operators.sns_publish_operator.SnsPublishOperator attribute) (airflow.contrib.operators.spark_sql_operator.SparkSqlOperator attribute) (airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator attribute) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.sqoop_operator.SqoopOperator attribute) (airflow.contrib.operators.ssh_operator.SSHOperator attribute) (airflow.contrib.operators.vertica_operator.VerticaOperator attribute) (airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer attribute) (airflow.contrib.operators.vertica_to_mysql.VerticaToMySqlTransfer attribute) (airflow.contrib.operators.wasb_delete_blob_operator.WasbDeleteBlobOperator attribute) (airflow.contrib.operators.winrm_operator.WinRMOperator attribute) (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor attribute) (airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor attribute) (airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor attribute) (airflow.contrib.sensors.aws_sqs_sensor.SQSSensor attribute) (airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor attribute) (airflow.contrib.sensors.bash_sensor.BashSensor attribute) (airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor attribute) (airflow.contrib.sensors.cassandra_record_sensor.CassandraRecordSensor attribute) (airflow.contrib.sensors.cassandra_table_sensor.CassandraTableSensor attribute) (airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor attribute) (airflow.contrib.sensors.emr_step_sensor.EmrStepSensor attribute) (airflow.contrib.sensors.file_sensor.FileSensor attribute) (airflow.contrib.sensors.ftp_sensor.FTPSensor attribute) (airflow.contrib.sensors.gcp_transfer_sensor.GCPTransferServiceWaitForJobStatusSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageUploadSessionCompleteSensor attribute) (airflow.contrib.sensors.imap_attachment_sensor.ImapAttachmentSensor attribute) (airflow.contrib.sensors.jira_sensor.JiraTicketSensor attribute) (airflow.contrib.sensors.mongo_sensor.MongoSensor attribute) (airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor attribute) (airflow.contrib.sensors.python_sensor.PythonSensor attribute) (airflow.contrib.sensors.qubole_sensor.QuboleSensor attribute) (airflow.contrib.sensors.redis_key_sensor.RedisKeySensor attribute) (airflow.contrib.sensors.redis_pub_sub_sensor.RedisPubSubSensor attribute) (airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor attribute) (airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor attribute) (airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor attribute) (airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor attribute) (airflow.contrib.sensors.sftp_sensor.SFTPSensor attribute) (airflow.contrib.sensors.wasb_sensor.WasbBlobSensor attribute) (airflow.contrib.sensors.wasb_sensor.WasbPrefixSensor attribute) (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) (airflow.operators.bash_operator.BashOperator attribute) (airflow.operators.check_operator.CheckOperator attribute) (airflow.operators.check_operator.IntervalCheckOperator attribute) (airflow.operators.check_operator.ValueCheckOperator attribute) (airflow.operators.dagrun_operator.TriggerDagRunOperator attribute) (airflow.operators.docker_operator.DockerOperator attribute) (airflow.operators.email_operator.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.hive_operator.HiveOperator attribute) (airflow.operators.hive_stats_operator.HiveStatsCollectionOperator attribute) (airflow.operators.hive_to_druid.HiveToDruidTransfer attribute) (airflow.operators.hive_to_mysql.HiveToMySqlTransfer attribute) (airflow.operators.hive_to_samba_operator.Hive2SambaOperator attribute) (airflow.operators.http_operator.SimpleHttpOperator attribute) (airflow.operators.jdbc_operator.JdbcOperator attribute) (airflow.operators.mssql_operator.MsSqlOperator attribute) (airflow.operators.mssql_to_hive.MsSqlToHiveTransfer attribute) (airflow.operators.mysql_operator.MySqlOperator attribute) (airflow.operators.mysql_to_hive.MySqlToHiveTransfer attribute) (airflow.operators.oracle_operator.OracleOperator attribute) (airflow.operators.pig_operator.PigOperator attribute) (airflow.operators.postgres_operator.PostgresOperator attribute) (airflow.operators.presto_to_mysql.PrestoToMySqlTransfer attribute) (airflow.operators.python_operator.PythonOperator attribute) (airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer attribute) (airflow.operators.s3_file_transform_operator.S3FileTransformOperator attribute) (airflow.operators.s3_to_hive_operator.S3ToHiveTransfer attribute) (airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer attribute) (airflow.operators.slack_operator.SlackAPIPostOperator attribute) (airflow.operators.sqlite_operator.SqliteOperator attribute) (airflow.sensors.external_task_sensor.ExternalTaskSensor attribute) (airflow.sensors.hdfs_sensor.HdfsSensor attribute) (airflow.sensors.hive_partition_sensor.HivePartitionSensor attribute) (airflow.sensors.http_sensor.HttpSensor attribute) (airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor attribute) (airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor attribute) (airflow.sensors.s3_key_sensor.S3KeySensor attribute) (airflow.sensors.s3_prefix_sensor.S3PrefixSensor attribute) (airflow.sensors.sql_sensor.SqlSensor attribute) (airflow.sensors.web_hdfs_sensor.WebHdfsSensor attribute)

terminate() (airflow.contrib.executors.kubernetes_executor.AirflowKubernetesScheduler method) (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) (airflow.executors.dask_executor.DaskExecutor method) terminate_cluster() (airflow.contrib.hooks.databricks_hook.DatabricksHook method) TERMINATE_CLUSTER_ENDPOINT (in module airflow.contrib.hooks.databricks_hook) test_cycle() (airflow.models.DAG method) (airflow.models.dag.DAG method) test_hql() (airflow.hooks.hive_hooks.HiveCliHook method) text_detection() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) TIME_TO_SLEEP_IN_SECONDS (in module airflow.contrib.hooks.gcp_cloud_build_hook) (in module airflow.contrib.hooks.gcp_compute_hook) (in module airflow.contrib.hooks.gcp_dlp_hook) (in module airflow.contrib.hooks.gcp_function_hook) (in module airflow.contrib.hooks.gcp_sql_hook) (in module airflow.contrib.hooks.gcp_transfer_hook) TimeDeltaSensor (class in airflow.operators.sensors) (class in airflow.sensors.time_delta_sensor) TimeSensor (class in airflow.operators.sensors) (class in airflow.sensors.time_sensor) timestamp (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute) timezone (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) to_csv() (airflow.hooks.hive_hooks.HiveServer2Hook method) to_json() (airflow.models.Pool method) (airflow.models.pool.Pool method) topological_sort() (airflow.models.DAG method) (airflow.models.dag.DAG method) TRANSFER_JOB (in module airflow.contrib.hooks.gcp_transfer_hook) TRANSFER_JOB_FIELD_MASK (in module airflow.contrib.hooks.gcp_transfer_hook) TRANSFER_JOBS (in module airflow.contrib.hooks.gcp_transfer_hook) TRANSFER_OPERATIONS (in module airflow.contrib.hooks.gcp_transfer_hook) TRANSFER_OPTIONS (in module airflow.contrib.hooks.gcp_transfer_hook) TRANSFER_SPEC (in module airflow.contrib.hooks.gcp_transfer_hook) TransferJobPreprocessor (class in airflow.contrib.operators.gcp_transfer_operator) TransferJobValidator (class in airflow.contrib.operators.gcp_transfer_operator) transform() (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator static method) transient_errors (airflow.contrib.sensors.ftp_sensor.FTPSensor attribute) translate() (airflow.contrib.hooks.gcp_translate_hook.CloudTranslateHook method) tree_view() (airflow.models.DAG method) (airflow.models.dag.DAG method) trigger_tasks() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) TriggerDagRunOperator (class in airflow.operators.dagrun_operator) try_number (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) ts_function() (in module airflow.contrib.sensors.gcs_sensor) tunnel() (airflow.contrib.operators.ssh_operator.SSHOperator method) type_map (airflow.contrib.operators.mssql_to_gcs.MsSqlToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator attribute) type_map() (airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer class method) (airflow.operators.mssql_to_hive.MsSqlToHiveTransfer class method) (airflow.operators.mysql_to_hive.MySqlToHiveTransfer class method) type_name (airflow.operators.papermill_operator.NoteBook attribute)

U

ui_color (airflow.contrib.operators.adls_list_operator.AzureDataLakeStorageListOperator attribute) (airflow.contrib.operators.adls_to_gcs.AdlsToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator attribute) (airflow.contrib.operators.aws_sqs_publish_operator.SQSPublishOperator attribute) (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator attribute) (airflow.contrib.operators.azure_cosmos_operator.AzureCosmosInsertDocumentOperator attribute) (airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryGetDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryPatchDatasetOperator attribute) (airflow.contrib.operators.bigquery_operator.BigQueryUpdateDatasetOperator attribute) (airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator attribute) (airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator attribute) (airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator attribute) (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.databricks_operator.DatabricksRunNowOperator attribute) (airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator attribute) (airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator attribute) (airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcHiveOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcPigOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcSparkOperator attribute) (airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator attribute) (airflow.contrib.operators.dingding_operator.DingdingOperator attribute) (airflow.contrib.operators.ecs_operator.ECSOperator attribute) (airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator attribute) (airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator attribute) (airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.GoogleCloudStorageToGoogleCloudStorageTransferOperator attribute) (airflow.contrib.operators.gcp_transfer_operator.S3ToGoogleCloudStorageTransferOperator attribute) (airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator attribute) (airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator attribute) (airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator attribute) (airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator attribute) (airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.gcs_to_s3.GoogleCloudStorageToS3Operator attribute) (airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator attribute) (airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBTransferOperator attribute) (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator attribute) (airflow.contrib.operators.mssql_to_gcs.MsSqlToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.oracle_to_azure_data_lake_transfer.OracleToAzureDataLakeTransfer attribute) (airflow.contrib.operators.oracle_to_oracle_transfer.OracleToOracleTransfer attribute) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubPublishOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubSubscriptionCreateOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubSubscriptionDeleteOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubTopicCreateOperator attribute) (airflow.contrib.operators.pubsub_operator.PubSubTopicDeleteOperator attribute) (airflow.contrib.operators.qubole_operator.QuboleOperator attribute) (airflow.contrib.operators.s3_list_operator.S3ListOperator attribute) (airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator attribute) (airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator attribute) (airflow.contrib.operators.snowflake_operator.SnowflakeOperator attribute) (airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator attribute) (airflow.contrib.operators.sql_to_gcs.BaseSQLToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.sqoop_operator.SqoopOperator attribute) (airflow.contrib.operators.vertica_operator.VerticaOperator attribute) (airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer attribute) (airflow.contrib.operators.vertica_to_mysql.VerticaToMySqlTransfer attribute) (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor attribute) (airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor attribute) (airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor attribute) (airflow.contrib.sensors.datadog_sensor.DatadogSensor attribute) (airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor attribute) (airflow.contrib.sensors.file_sensor.FileSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor attribute) (airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageUploadSessionCompleteSensor attribute) (airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor attribute) (airflow.contrib.sensors.redis_key_sensor.RedisKeySensor attribute) (airflow.contrib.sensors.redis_pub_sub_sensor.RedisPubSubSensor attribute) (airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor attribute) (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) (airflow.operators.bash_operator.BashOperator attribute) (airflow.operators.check_operator.CheckOperator attribute) (airflow.operators.check_operator.IntervalCheckOperator attribute) (airflow.operators.check_operator.ValueCheckOperator attribute) (airflow.operators.dagrun_operator.TriggerDagRunOperator attribute) (airflow.operators.dummy_operator.DummyOperator attribute) (airflow.operators.email_operator.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.hive_operator.HiveOperator attribute) (airflow.operators.hive_stats_operator.HiveStatsCollectionOperator attribute) (airflow.operators.hive_to_mysql.HiveToMySqlTransfer attribute) (airflow.operators.http_operator.SimpleHttpOperator attribute) (airflow.operators.jdbc_operator.JdbcOperator attribute) (airflow.operators.latest_only_operator.LatestOnlyOperator attribute) (airflow.operators.mssql_operator.MsSqlOperator attribute) (airflow.operators.mssql_to_hive.MsSqlToHiveTransfer attribute) (airflow.operators.mysql_operator.MySqlOperator attribute) (airflow.operators.mysql_to_hive.MySqlToHiveTransfer attribute) (airflow.operators.oracle_operator.OracleOperator attribute) (airflow.operators.pig_operator.PigOperator attribute) (airflow.operators.postgres_operator.PostgresOperator attribute) (airflow.operators.presto_to_mysql.PrestoToMySqlTransfer attribute) (airflow.operators.python_operator.PythonOperator attribute) (airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer attribute) (airflow.operators.s3_file_transform_operator.S3FileTransformOperator attribute) (airflow.operators.s3_to_hive_operator.S3ToHiveTransfer attribute) (airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer attribute) (airflow.operators.slack_operator.SlackAPIPostOperator attribute) (airflow.operators.sqlite_operator.SqliteOperator attribute) (airflow.operators.subdag_operator.SubDagOperator attribute) (airflow.sensors.base_sensor_operator.BaseSensorOperator attribute) (airflow.sensors.external_task_sensor.ExternalTaskSensor attribute) (airflow.sensors.hdfs_sensor.HdfsSensor attribute) (airflow.sensors.hive_partition_sensor.HivePartitionSensor attribute) (airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor attribute) (airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor attribute) (airflow.sensors.sql_sensor.SqlSensor attribute)

ui_fgcolor (airflow.contrib.operators.databricks_operator.DatabricksRunNowOperator attribute) (airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator attribute) (airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator attribute) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator attribute) (airflow.contrib.operators.qubole_operator.QuboleOperator attribute) (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) (airflow.operators.subdag_operator.SubDagOperator attribute) UNIT_TEST_MODE (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) UNIX_PATH_MAX (in module airflow.contrib.hooks.gcp_sql_hook) unixname (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) UNKNOWN (airflow.contrib.hooks.gcp_sql_hook.CloudSqlOperationStatus attribute) update_cluster() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook static method) update_database() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) update_dataset() (airflow.contrib.hooks.bigquery_hook.BigQueryBaseCursor method) update_deidentify_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) update_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) UPDATE_FUNCTION (airflow.contrib.hooks.openfaas_hook.OpenFaasHook attribute) update_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) (airflow.contrib.hooks.openfaas_hook.OpenFaasHook method) update_inspect_template() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) update_instance() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook method) update_job_trigger() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) update_many() (airflow.contrib.hooks.mongo_hook.MongoHook method) update_one() (airflow.contrib.hooks.mongo_hook.MongoHook method) update_product() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) update_product_set() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) update_state() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) update_stored_info_type() (airflow.contrib.hooks.gcp_dlp_hook.CloudDLPHook method) update_transfer_job() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) upload() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) upload_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method) upload_function (airflow.contrib.operators.gcp_function_operator.ZipPathPreprocessor attribute) upload_function_zip() (airflow.contrib.hooks.gcp_function_hook.GcfHook method) upsert_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) upstream_list (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) upstream_task_ids (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.BaseOperator attribute) used_slots() (airflow.models.Pool method) (airflow.models.pool.Pool method) User (class in airflow.models) (class in airflow.models.user) USER_AGENT_HEADER (in module airflow.contrib.hooks.databricks_hook) user_id (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) (airflow.models.KnownEvent attribute) (airflow.models.knownevent.KnownEvent attribute) username (airflow.models.User attribute) (airflow.models.user.User attribute)

V

val (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) valid_modes (airflow.sensors.base_sensor_operator.BaseSensorOperator attribute) validate_body() (airflow.contrib.operators.gcp_transfer_operator.TransferJobValidator method) validate_response() (airflow.contrib.hooks.datadog_hook.DatadogHook method) validate_socket_path_length() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) validate_ssl_certs() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method) value (airflow.models.XCom attribute) (airflow.models.xcom.XCom attribute)

ValueCheckOperator (class in airflow.operators.check_operator) Variable (class in airflow.models) (class in airflow.models.variable) verify_integrity() (airflow.models.DagRun method) (airflow.models.dagrun.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) VerticaToMySqlTransfer (class in airflow.contrib.operators.vertica_to_mysql) Volume (in module airflow.contrib.operators.azure_container_instances_operator)

W

wait() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method) wait_for_done() (airflow.contrib.hooks.gcp_dataflow_hook._Dataflow method) (airflow.contrib.hooks.gcp_dataflow_hook._DataflowJob method) (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJob method) (airflow.contrib.hooks.gcp_dataproc_hook._DataProcOperation method) wait_for_operation() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method) wait_for_transfer_job() (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) WAIT_IN_PROGRESS (airflow.contrib.hooks.sagemaker_hook.LogState attribute) WasbBlobSensor (class in airflow.contrib.sensors.wasb_sensor) WasbDeleteBlobOperator (class in airflow.contrib.operators.wasb_delete_blob_operator) WasbHook (class in airflow.contrib.hooks.wasb_hook)

WasbPrefixSensor (class in airflow.contrib.sensors.wasb_sensor) WebHDFSHook (class in airflow.hooks.webhdfs_hook) WebHdfsSensor (class in airflow.operators.sensors) (class in airflow.sensors.web_hdfs_sensor) WILDCARD (in module airflow.contrib.operators.gcs_to_gcs) WinRMHook (class in airflow.contrib.hooks.winrm_hook) WinRMOperator (class in airflow.contrib.operators.winrm_operator) worker_uuid (airflow.models.kubernetes.KubeWorkerIdentifier attribute) (airflow.models.KubeWorkerIdentifier attribute) write_batch_data() (airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook method) write_object_to_file() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)

X

x_is_date (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute) XCom (class in airflow.models) (class in airflow.models.xcom) xcom_pull() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.operators.BaseOperator method)

xcom_push() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.operators.BaseOperator method) XCOM_RETURN_KEY (in module airflow.models) (in module airflow.models.xcom) XCOM_RUN_ID_KEY (in module airflow.contrib.operators.databricks_operator) XCOM_RUN_PAGE_URL_KEY (in module airflow.contrib.operators.databricks_operator)

Y

y_log_scale (airflow.models.Chart attribute) (airflow.models.chart.Chart attribute)

YEAR (in module airflow.contrib.hooks.gcp_transfer_hook)

Z

ZendeskHook (class in airflow.hooks.zendesk_hook)

ZipPathPreprocessor (class in airflow.contrib.operators.gcp_function_operator)

PreviousNext

Was this entry helpful?