Index

_

__call__() (airflow.contrib.hooks.databricks_hook._TokenAuth method) __deepcopy__() (airflow.models.BaseOperator method) (airflow.models.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.timeout method) __eq__() (airflow.contrib.hooks.databricks_hook.RunState method) (airflow.models.BaseOperator method) (airflow.models.DAG method) (airflow.models.Resources 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.timeout 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.operators.BaseOperator method) __handle_rate_limit_exception() (airflow.hooks.zendesk_hook.ZendeskHook method) __hash__() (airflow.models.BaseOperator method) (airflow.models.DAG method) (airflow.operators.BaseOperator method) __login() (airflow.hooks.docker_hook.DockerHook method) __lshift__() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) __lt__() (airflow.models.BaseOperator method) (airflow.models.DAG method) (airflow.operators.BaseOperator method) __mapper_args__ (airflow.operators.check_operator.IntervalCheckOperator attribute) (airflow.operators.check_operator.ValueCheckOperator attribute) __metaclass__ (airflow.models.BaseDag attribute) __ne__() (airflow.models.BaseOperator method) (airflow.models.DAG method) (airflow.operators.BaseOperator method) __NO_DEFAULT_SENTINEL (airflow.models.Variable attribute) __repr__() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutorConfig method) (airflow.contrib.hooks.databricks_hook.RunState method) (airflow.models.BaseOperator method) (airflow.models.Chart method) (airflow.models.Connection method) (airflow.models.DAG method) (airflow.models.DagModel method) (airflow.models.DagRun method) (airflow.models.KnownEvent method) (airflow.models.KnownEventType method) (airflow.models.Pool method) (airflow.models.Resources method) (airflow.models.SlaMiss method) (airflow.models.TaskInstance method) (airflow.models.User method) (airflow.models.Variable method) (airflow.models.XCom method) (airflow.models.connection.Connection method) (airflow.models.slamiss.SlaMiss method) (airflow.operators.BaseOperator method) __rlshift__() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) __rrshift__() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) __rshift__() (airflow.models.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.operators.BaseOperator method) __table_args__ (airflow.models.DagRun attribute) (airflow.models.Log attribute) (airflow.models.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.log.Log attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskreschedule.TaskReschedule attribute) __tablename__ (airflow.models.Chart attribute) (airflow.models.Connection attribute) (airflow.models.DagModel attribute) (airflow.models.DagPickle attribute) (airflow.models.DagRun attribute) (airflow.models.ImportError attribute) (airflow.models.KnownEvent attribute) (airflow.models.KnownEventType attribute) (airflow.models.KubeResourceVersion attribute) (airflow.models.KubeWorkerIdentifier attribute) (airflow.models.Log attribute) (airflow.models.Pool attribute) (airflow.models.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.User attribute) (airflow.models.Variable attribute) (airflow.models.XCom attribute) (airflow.models.connection.Connection attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.errors.ImportError attribute) (airflow.models.kubernetes.KubeResourceVersion attribute) (airflow.models.kubernetes.KubeWorkerIdentifier attribute) (airflow.models.log.Log attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskreschedule.TaskReschedule attribute) _ALL_TRIGGER_RULES (airflow.models.TriggerRule attribute) _ALL_WEIGHT_RULES (airflow.models.WeightRule attribute) _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.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_jdbc_application_arguments() (airflow.contrib.hooks.spark_jdbc_hook.SparkJDBCHook 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) _check_done() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcOperation 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_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_translate_hook.CloudTranslateHook attribute) (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook attribute) _cluster_ready() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _compare_column_families() (airflow.contrib.operators.gcp_bigtable_operator.BigtableTableCreateOperator method) _configure_csv_file() (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) _conn (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) _CONTEXT_MANAGER_DAG (in module airflow.models) _convert_date_to_dict() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor 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) _convert_types() (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator static 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_skip_downstream_tasks() (airflow.sensors.base_sensor_operator.BaseSensorOperator method) _download_sql_proxy_if_needed() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method) _escape() (in module airflow.contrib.hooks.bigquery_hook) _evaluate_trigger_rule() (airflow.models.TriggerRuleDep method) _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) _fetch_mail_body() (airflow.contrib.hooks.imap_hook.ImapHook 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) _G_APP_CRED_ENV_VAR (in module airflow.contrib.hooks.gcp_api_base_hook) _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) _get_cluster() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _get_cluster_list_for_project() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _get_cluster_state() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) _get_col_type_dict() (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) _get_concurrency_reached() (airflow.models.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_dep_statuses() (airflow.models.NotInRetryPeriodDep method) (airflow.models.PrevDagrunDep method) (airflow.models.TriggerRuleDep 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.operators.gcp_container_operator.GKEPodOperator 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_instance_view() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) _get_is_paused() (airflow.models.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) _get_max_partition_from_part_specs() (airflow.hooks.hive_hooks.HiveMetastoreHook static method) _get_pretty_exception_message() (airflow.hooks.presto_hook.PrestoHook static method) _get_previous_ti() (airflow.models.TaskInstance method) _get_project_id() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook method) _get_results() (airflow.hooks.hive_hooks.HiveServer2Hook 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_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) _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) _query_mysql() (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) _query_postgres() (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator 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_schedule() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor method) _reformat_time() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor 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) _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) (airflow.models.LoggingMixin method) _set_env_from_extras() (airflow.contrib.operators.gcp_container_operator.GKEPodOperator method) _set_relatives() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator 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) _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) _to_timestamp() (airflow.contrib.hooks.salesforce_hook.SalesforceHook class method) _TokenAuth (class in airflow.contrib.hooks.databricks_hook) _try_number (airflow.models.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.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator method) _val (airflow.models.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_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_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_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_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_done() (airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method) (airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator static method) (airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator method) _wait_for_job_done() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) _wait_for_operation_to_complete() (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.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator method) _write_local_schema_file() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator method) (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator 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) ABSOLUTE (airflow.models.WeightRule 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_only_new() (airflow.models.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) add_tasks() (airflow.models.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_sns_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_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_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_sql_hook (module) airflow.contrib.hooks.gcp_transfer_hook (module) airflow.contrib.hooks.gcp_translate_hook (module) airflow.contrib.hooks.gcp_vision_hook (module) airflow.contrib.hooks.gcs_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.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_compute_operator (module) airflow.contrib.operators.gcp_container_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_sql_operator (module) airflow.contrib.operators.gcp_transfer_operator (module) airflow.contrib.operators.gcp_translate_operator (module) airflow.contrib.operators.gcp_vision_operator (module) airflow.contrib.operators.gcs_acl_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.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.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.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.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.connection (module) airflow.models.dagpickle (module) airflow.models.errors (module) airflow.models.kubernetes (module) airflow.models.log (module) airflow.models.skipmixin (module) airflow.models.slamiss (module) airflow.models.taskfail (module) airflow.models.taskreschedule (module) airflow.operators (module) airflow.operators.bash_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.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) AirflowDagCycleException AirflowException, [1] AirflowKubernetesScheduler (class in airflow.contrib.executors.kubernetes_executor) AirflowMesosScheduler (class in airflow.contrib.executors.mesos_executor) AirflowRescheduleException AirflowSkipException AirflowTaskTimeout AirflowWebHDFSHookException ALL_DONE (airflow.models.TriggerRule attribute) ALL_FAILED (airflow.models.TriggerRule attribute) ALL_SUCCESS (airflow.models.TriggerRule attribute) all_triggers() (airflow.models.TriggerRule class method) all_weight_rules() (airflow.models.WeightRule class method) 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) annotator_client() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) app (in module airflow.executors.celery_executor) apply_defaults (in module airflow.models) apply_lineage() (in module airflow.models) are_dependencies_met() (airflow.models.TaskInstance method) are_dependents_done() (airflow.models.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) as_tuple() (in module airflow.models) AthenaSensor (class in airflow.contrib.sensors.aws_athena_sensor) attr_keys (airflow.models.Interval 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) 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) Base (in module airflow.models) (in module airflow.models.base) BaseDag (class in airflow.models) BaseDagBag (class in airflow.models) 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.operators) BaseSensorOperator (class in airflow.operators.sensors) (class in airflow.sensors.base_sensor_operator) BashOperator (class in airflow.operators.bash_operator) BashSensor (class in airflow.contrib.sensors.bash_sensor) begin_transaction() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) 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) 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) 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) 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) 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_job() (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method) 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_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) chart_type (airflow.models.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) 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.DAG method) (airflow.operators.BaseOperator method) clear_dags() (airflow.models.DAG class method) clear_not_launched_queued_tasks() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) clear_task_instances() (in module airflow.models) clear_xcom_data() (airflow.models.TaskInstance method) cli() (airflow.models.DAG method) 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) 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) CloudVisionAddProductToProductSetOperator (class in airflow.contrib.operators.gcp_vision_operator) CloudVisionAnnotateImageOperator (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) color() (airflow.models.State class method) color_fg() (airflow.models.State class method) command() (airflow.models.TaskInstance method) COMMAND_ARGS (in module airflow.contrib.hooks.qubole_hook) command_as_list() (airflow.models.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) concurrency() (airflow.models.BaseDag method) concurrency_reached (airflow.models.DAG attribute) conf (airflow.models.DagRun attribute) 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.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_types() (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class 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_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.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_directory() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method) (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook 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_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) 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_reference_image() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook 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) cron_presets (in module airflow.models) current_state() (airflow.models.TaskInstance method) cursor() (airflow.contrib.hooks.bigquery_hook.BigQueryConnection method) CYCLE_DONE (airflow.models.DagBag attribute) CYCLE_IN_PROGRESS (airflow.models.DagBag attribute) CYCLE_NEW (airflow.models.DagBag attribute)

D

dag (airflow.models.BaseOperator attribute) (airflow.models.DagRun attribute) (airflow.operators.BaseOperator attribute) DAG (class in airflow.models) dag_id (airflow.models.BaseDag attribute) (airflow.models.BaseOperator attribute) (airflow.models.DAG attribute) (airflow.models.DagModel attribute) (airflow.models.DagRun attribute) (airflow.models.Log attribute) (airflow.models.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.log.Log attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.operators.BaseOperator attribute) dag_ids (airflow.models.BaseDagBag attribute) (airflow.models.DagBag attribute) dag_states (airflow.models.State attribute) DagBag (class in airflow.models) dagbag_report() (airflow.models.DagBag method) DagModel (class in airflow.models) DagPickle (class in airflow.models) (class in airflow.models.dagpickle) DagRun (class in airflow.models) 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) 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) DataprocWorkflowTemplateBaseOperator (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) 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) deactivate_unknown_dags() (airflow.models.DAG static method) debug_info() (airflow.models.Connection method) (airflow.models.connection.Connection method) decrpyt() (airflow.models.NullFernet method) decrypt() (airflow.contrib.hooks.gcp_kms_hook.GoogleCloudKMSHook 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) DEFAULT_TARGET_PARTITION_SIZE (in module airflow.operators.hive_to_druid) default_view (airflow.models.DagModel attribute) DEFAULT_VOLUMES (in module airflow.contrib.operators.azure_container_instances_operator) delete() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) (airflow.models.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_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.sftp_hook.SFTPHook method) delete_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method) 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_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_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_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) DepContext (class in airflow.models) DEPLOY_FUNCTION (airflow.contrib.hooks.openfaas_hook.OpenFaasHook attribute) deploy_function() (airflow.contrib.hooks.openfaas_hook.OpenFaasHook method) deps (airflow.models.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.DagModel attribute) (airflow.models.KnownEvent attribute) (airflow.models.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) DockerHook (class in airflow.hooks.docker_hook) DockerOperator (class in airflow.operators.docker_operator) 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 (airflow.models.WeightRule attribute) downstream_list (airflow.models.BaseOperator attribute) (airflow.operators.BaseOperator attribute) downstream_task_ids (airflow.models.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.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) DUMMY (airflow.models.TriggerRule attribute) DummyOperator (class in airflow.operators.dummy_operator) duration (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskreschedule.TaskReschedule attribute)

E

ECSOperator (class in airflow.contrib.operators.ecs_operator) email (airflow.models.User attribute) email_alert() (airflow.models.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.NullFernet method) end() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method) (airflow.contrib.executors.mesos_executor.MesosExecutor method) (airflow.executors.BaseExecutor method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) (airflow.executors.SequentialExecutor method) (airflow.executors.base_executor.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.sequential_executor.SequentialExecutor method) (airflow.models.LocalExecutor method) (airflow.models.LocalExecutor._LimitedParallelism method) (airflow.models.LocalExecutor._UnlimitedParallelism method) end_date (airflow.models.DagRun attribute) (airflow.models.KnownEvent attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskfail.TaskFail 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) 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) 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.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.BigQueryOperator 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.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.dataproc_operator.DataprocClusterCreateOperator method) (airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator method) (airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator method) (airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateBaseOperator 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_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_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_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_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_vision_operator.CloudVisionAddProductToProductSetOperator method) (airflow.contrib.operators.gcp_vision_operator.CloudVisionAnnotateImageOperator 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_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.mysql_to_gcs.MySqlToGoogleCloudStorageOperator 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.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator 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.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.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.operators.BaseOperator method) (airflow.operators.bash_operator.BashOperator 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.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.BaseExecutor method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) (airflow.executors.SequentialExecutor method) (airflow.executors.base_executor.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.sequential_executor.SequentialExecutor method) (airflow.models.LocalExecutor method) (airflow.models.LocalExecutor._LimitedParallelism method) (airflow.models.LocalExecutor._UnlimitedParallelism 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.Log attribute) (airflow.models.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.log.Log attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskreschedule.TaskReschedule attribute) executor_config (airflow.models.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) ExternalTaskSensor (class in airflow.operators.sensors) (class in airflow.sensors.external_task_sensor) extra (airflow.models.Connection attribute) (airflow.models.Log attribute) (airflow.models.connection.Connection attribute) (airflow.models.log.Log attribute) extra_dejson (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute)

F

fail() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) FAILED (airflow.contrib.hooks.gcp_transfer_hook.GcpTransferOperationStatus attribute) (airflow.models.State 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_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) fileloc (airflow.models.DagModel attribute) filename (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) filepath (airflow.models.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_PROJECT_ID (in module airflow.contrib.hooks.gcp_transfer_hook) find() (airflow.contrib.hooks.mongo_hook.MongoHook method) (airflow.models.DagRun static method) find_for_task_instance() (airflow.models.TaskReschedule static method) (airflow.models.taskreschedule.TaskReschedule static method) finished() (airflow.models.State class method) folder (airflow.models.DAG attribute) following_schedule() (airflow.models.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.BaseDag attribute) (airflow.models.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

G_APP_CRED (in module airflow.contrib.operators.gcp_container_operator) 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) 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) 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) 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) get_active_runs() (airflow.models.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_sns_hook.AwsSnsHook 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_compute_hook.GceHook method) (airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method) (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook 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_sql_hook.CloudSqlHook method) (airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method) (airflow.contrib.hooks.gcp_translate_hook.CloudTranslateHook method) (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook 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.S3_hook.S3Hook 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.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.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.BaseDagBag method) (airflow.models.DagBag method) (airflow.models.DagModel method) (airflow.models.DagRun method) get_dagmodel() (airflow.models.DagModel static method) get_dagrun() (airflow.models.DAG method) (airflow.models.TaskInstance 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_exprs() (airflow.operators.hive_stats_operator.HiveStatsCollectionOperator method) get_default_view() (airflow.models.DAG method) (airflow.models.DagModel method) get_direct_relative_ids() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) get_direct_relatives() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator 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_failed_dep_statuses() (airflow.models.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) 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.operators.BaseOperator method) get_flat_relatives() (airflow.models.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_hostname() (in module airflow.models) get_id() (airflow.models.User 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_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.DagModel method) (in module airflow.models) get_latest_runs() (airflow.models.DagRun class method) get_lb_policy() (airflow.contrib.hooks.cassandra_hook.CassandraHook static 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_logs() (airflow.contrib.hooks.azure_container_instance_hook.AzureContainerInstanceHook method) get_many() (airflow.models.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) get_num_running_task_instances() (airflow.models.TaskInstance method) get_num_task_instances() (airflow.models.DAG static method) get_object_from_salesforce() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method) get_one() (airflow.models.XCom class method) get_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method) (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method) 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_previous_dagrun() (airflow.models.DagRun method) get_previous_scheduled_dagrun() (airflow.models.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) get_run_dates() (airflow.models.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.models.DagRun 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_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) get_task_instance() (airflow.models.DagRun method) get_task_instances() (airflow.models.BaseOperator method) (airflow.models.DAG method) (airflow.models.DagRun method) (airflow.operators.BaseOperator method) get_template_context() (airflow.models.TaskInstance method) get_template_env() (airflow.models.BaseOperator method) (airflow.models.DAG method) (airflow.operators.BaseOperator method) 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) get_wildcard_key() (airflow.hooks.S3_hook.S3Hook method) GetDefaultExecutor() (in module airflow.executors) (in module airflow.models) 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) 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) 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)

H

handle_airflow_exception() (in module airflow.contrib.operators.qubole_check_operator) handle_callback() (airflow.models.DAG method) handle_failure() (airflow.models.TaskInstance method) handle_failure_retry() (airflow.contrib.hooks.qubole_check_hook.QuboleCheckHook static method) (airflow.contrib.hooks.qubole_hook.QuboleHook static method) handle_timeout() (airflow.models.timeout method) has_attachments() (airflow.contrib.hooks.imap_hook.Mail method) has_dag() (airflow.models.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) 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) (airflow.executors.celery_executor.CeleryExecutor method)

height (airflow.models.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) 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) HYPHEN_ARGS (in module airflow.contrib.hooks.qubole_hook)

I

id (airflow.models.Chart attribute) (airflow.models.Connection attribute) (airflow.models.DagPickle attribute) (airflow.models.DagRun attribute) (airflow.models.ImportError attribute) (airflow.models.KnownEvent attribute) (airflow.models.KnownEventType attribute) (airflow.models.Log attribute) (airflow.models.Pool attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskReschedule attribute) (airflow.models.User attribute) (airflow.models.Variable attribute) (airflow.models.XCom attribute) (airflow.models.connection.Connection attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.errors.ImportError attribute) (airflow.models.log.Log attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskreschedule.TaskReschedule attribute) id_for_date() (airflow.models.DagRun class method) ID_FORMAT_PREFIX (airflow.models.DagRun attribute) ID_LEN (in module airflow.models) (in module airflow.models.base) ID_PREFIX (airflow.models.DagRun attribute) IGNOREABLE (airflow.models.NotInRetryPeriodDep attribute) (airflow.models.PrevDagrunDep attribute) (airflow.models.TriggerRuleDep 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) impl (airflow.models.Interval attribute) (airflow.models.UtcDateTime attribute) 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.XCom method) init_run_context() (airflow.models.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)

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) Interval (class in airflow.models) IntervalCheckOperator (class in airflow.operators.check_operator) 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.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) is_container() (in module airflow.models) is_eligible_to_retry() (airflow.models.TaskInstance method) is_encrypted (airflow.models.Connection attribute) (airflow.models.NullFernet attribute) (airflow.models.Variable attribute) (airflow.models.connection.Connection attribute) is_extra_encrypted (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) is_fixed_time_schedule() (airflow.models.DAG method) is_paused (airflow.models.DAG attribute) (airflow.models.DagModel attribute) is_paused() (airflow.models.BaseDag method) is_paused_at_creation (airflow.models.DagModel attribute) is_premature (airflow.models.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_subdag (airflow.models.DagModel attribute) is_successful (airflow.contrib.hooks.databricks_hook.RunState attribute) is_superuser() (airflow.models.User method) IS_TASK_DEP (airflow.models.NotInRetryPeriodDep attribute) (airflow.models.PrevDagrunDep attribute) (airflow.models.TriggerRuleDep attribute) is_terminal (airflow.contrib.hooks.databricks_hook.RunState attribute) is_updated_after() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method) is_valid() (airflow.models.TriggerRule class method) (airflow.models.WeightRule class 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)

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)

K

key (airflow.models.TaskInstance attribute) (airflow.models.Variable attribute) (airflow.models.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) know_event_type (airflow.models.KnownEventType attribute) known_event_type_id (airflow.models.KnownEvent attribute) KnownEvent (class in airflow.models) KnownEventType (class in airflow.models)

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.KnownEvent attribute) last_expired (airflow.models.DagModel attribute) last_modified (airflow.models.Chart attribute) last_pickled (airflow.models.DagModel attribute) last_scheduler_run (airflow.models.DagModel attribute) latest_execution_date (airflow.models.DAG attribute) LatestOnlyOperator (class in airflow.operators.latest_only_operator) list() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook 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_keys() (airflow.hooks.S3_hook.S3Hook method) list_prefixes() (airflow.hooks.S3_hook.S3Hook method) list_py_file_paths() (in module airflow.models) 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.S3_hook.S3Hook method) (airflow.hooks.hive_hooks.HiveCliHook 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) (class in airflow.models) LocalExecutor._LimitedParallelism (class in airflow.executors) (class in airflow.executors.local_executor) (class in airflow.models) LocalExecutor._UnlimitedParallelism (class in airflow.executors) (class in airflow.executors.local_executor) (class in airflow.models) LocalWorker (class in airflow.executors.local_executor) log (airflow.executors.LoggingMixin attribute) (airflow.models.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) log_stream() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method) log_url (airflow.models.TaskInstance attribute) logger (airflow.executors.LoggingMixin attribute) (airflow.models.LoggingMixin attribute) LoggingMixin (class in airflow.executors) (class in airflow.models) 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) MAX_PART_COUNT (airflow.hooks.hive_hooks.HiveMetastoreHook attribute) max_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method) (in module airflow.macros.hive) max_tries (airflow.models.TaskInstance attribute) 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) 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.models.NotInRetryPeriodDep attribute) (airflow.models.PrevDagrunDep attribute) (airflow.models.TriggerRuleDep attribute) (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) next_try_number (airflow.models.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)

NONE (airflow.models.State attribute) NONE_FAILED (airflow.models.TriggerRule attribute) NONE_SKIPPED (airflow.models.TriggerRule attribute) normalize_schedule() (airflow.models.DAG method) notification_sent (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) NotInRetryPeriodDep (class in airflow.models) NullFernet (class in airflow.models) NUM_RETRIES (in module airflow.contrib.hooks.gcp_compute_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)

O

OBJECT_CONDITIONS (in module airflow.contrib.hooks.gcp_transfer_hook) 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.bigquery_operator.BigQueryOperator 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.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.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_FAILED (airflow.models.TriggerRule attribute)

one_row_id (airflow.models.KubeResourceVersion attribute) (airflow.models.KubeWorkerIdentifier attribute) (airflow.models.kubernetes.KubeResourceVersion attribute) (airflow.models.kubernetes.KubeWorkerIdentifier attribute) ONE_SUCCESS (airflow.models.TriggerRule attribute) open_slots() (airflow.models.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) 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) owner (airflow.models.Chart attribute) (airflow.models.DAG attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) owners (airflow.models.DagModel attribute)

P

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_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) pickle_hash (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) pickle_id (airflow.models.DAG attribute) (airflow.models.DagModel attribute) pickle_id() (airflow.models.BaseDag method) pickle_info() (airflow.models.DAG method) pid (airflow.models.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.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.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.TaskInstance attribute) Pool (class in airflow.models) pool_full() (airflow.models.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.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) pprinttable() (in module airflow.models) pre_execute() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) prepare_lineage() (in module airflow.models) prepare_request() (airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method) (airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator method) prepare_template() (airflow.models.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) PrevDagrunDep (class in airflow.models) previous_schedule() (airflow.models.DAG method) previous_ti (airflow.models.TaskInstance attribute) priority_weight (airflow.models.TaskInstance attribute) priority_weight_total (airflow.models.BaseOperator attribute) (airflow.operators.BaseOperator attribute) process_bind_param() (airflow.models.Interval method) (airflow.models.UtcDateTime method) process_body() (airflow.contrib.operators.gcp_transfer_operator.TransferJobPreprocessor method) process_error() (airflow.contrib.executors.kubernetes_executor.KubernetesJobWatcher method) process_file() (airflow.models.DagBag method) process_result_value() (airflow.models.Interval method) (airflow.models.UtcDateTime 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) provide_session() (in module airflow.models) 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) PythonOperator (class in airflow.operators.python_operator) PythonSensor (class in airflow.contrib.sensors.python_sensor) PythonVirtualenvOperator (class in airflow.operators.python_operator)

Q

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_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method)

queue (airflow.models.TaskInstance attribute) queue_command() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) QUEUE_DEPS (in module airflow.models) queue_task_instance() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.BaseExecutor method) QUEUED (airflow.models.State attribute) queued_dttm (airflow.models.TaskInstance attribute) queued_slots() (airflow.models.Pool method) QueuedLocalWorker (class in airflow.executors.local_executor)

R

raise_error() (airflow.contrib.hooks.gcp_dataproc_hook._DataProcJob method) random() (in module airflow.macros) read_file() (airflow.contrib.hooks.wasb_hook.WasbHook method) read_key() (airflow.hooks.S3_hook.S3Hook method) ready_for_retry() (airflow.models.TaskInstance method) record_exists() (airflow.contrib.hooks.cassandra_hook.CassandraHook method) RedisHook (class in airflow.contrib.hooks.redis_hook) RedisKeySensor (class in airflow.contrib.sensors.redis_key_sensor) 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.TaskInstance method) registered() (airflow.contrib.executors.mesos_executor.AirflowMesosScheduler method) remove_product_from_product_set() (airflow.contrib.hooks.gcp_vision_hook.CloudVisionHook method) REMOVED (airflow.models.State attribute) rename() (airflow.contrib.hooks.ftp_hook.FTPHook method) render_template() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) render_template_from_field() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) render_templates() (airflow.models.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) 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.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) Resources (class in airflow.models) 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) 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) rotate_fernet_key() (airflow.models.Connection method) (airflow.models.Variable method) (airflow.models.connection.Connection 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.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.DAG method) (airflow.models.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_DEPS (in module airflow.models) 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) 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) (airflow.models.State 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.DagModel attribute) 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.DagModel attribute) (airflow.operators.BaseOperator attribute) SCHEDULE_START_DATE (in module airflow.contrib.hooks.gcp_transfer_hook) SCHEDULED (airflow.models.State attribute) scheduler_lock (airflow.models.DagModel 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_email() (in module airflow.models) 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) set() (airflow.models.Variable class method) (airflow.models.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) set_default_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method) set_dependency() (airflow.models.DAG method) set_downstream() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) set_duration() (airflow.models.TaskInstance method) set_extra() (airflow.models.Connection method) (airflow.models.connection.Connection 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.TaskInstance method) set_upstream() (airflow.models.BaseOperator method) (airflow.operators.BaseOperator method) set_val() (airflow.models.Variable method) setdefault() (airflow.models.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.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) show_sql (airflow.models.Chart attribute) SHUTDOWN (airflow.models.State 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) skip() (airflow.models.SkipMixin method) (airflow.models.skipmixin.SkipMixin method) SkipMixin (class in airflow.models) (class in airflow.models.skipmixin) SKIPPED (airflow.models.State attribute) 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) 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) SQL_ALCHEMY_SCHEMA (in module airflow.models.base) sql_layout (airflow.models.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) 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.DataprocWorkflowTemplateBaseOperator method) (airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateInlineOperator method) (airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateOperator method) (airflow.executors.BaseExecutor method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) (airflow.executors.base_executor.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.models.LocalExecutor method) (airflow.models.LocalExecutor._LimitedParallelism method) (airflow.models.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.KnownEvent attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskfail.TaskFail 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.TaskInstance attribute) State (class in airflow.models) state_color (airflow.models.State 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) Stats (in module airflow.models) STATUS (in module airflow.contrib.hooks.gcp_transfer_hook) STATUS1 (in module airflow.contrib.hooks.gcp_transfer_hook) status_code (airflow.executors.AirflowException attribute) (airflow.models.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) SubDagOperator (class in airflow.operators.subdag_operator) subdags (airflow.models.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) (airflow.models.State 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) 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.BaseExecutor method) (airflow.executors.LocalExecutor method) (airflow.executors.LocalExecutor._LimitedParallelism method) (airflow.executors.LocalExecutor._UnlimitedParallelism method) (airflow.executors.SequentialExecutor method) (airflow.executors.base_executor.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.sequential_executor.SequentialExecutor method) (airflow.models.LocalExecutor method) (airflow.models.LocalExecutor._LimitedParallelism method) (airflow.models.LocalExecutor._UnlimitedParallelism method) sync_to_db() (airflow.models.DAG 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.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.XCom attribute) (airflow.models.log.Log attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskreschedule.TaskReschedule attribute) task_ids (airflow.models.BaseDag attribute) (airflow.models.DAG attribute) task_states (airflow.models.State attribute) task_type (airflow.models.BaseOperator attribute) (airflow.operators.BaseOperator attribute) TaskFail (class in airflow.models) (class in airflow.models.taskfail) TaskInstance (class in airflow.models) TaskReschedule (class in airflow.models) (class in airflow.models.taskreschedule) tasks (airflow.models.DAG attribute) template_ext (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.mysql_to_gcs.MySqlToGoogleCloudStorageOperator attribute) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator 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.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.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor 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.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.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_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.BigQueryOperator 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.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.DataprocClusterCreateOperator attribute) (airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator attribute) (airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator 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_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_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_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_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_vision_operator.CloudVisionAddProductToProductSetOperator attribute) (airflow.contrib.operators.gcp_vision_operator.CloudVisionAnnotateImageOperator 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_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.mysql_to_gcs.MySqlToGoogleCloudStorageOperator 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.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_check_operator.QuboleCheckOperator attribute) (airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator attribute) (airflow.contrib.operators.qubole_operator.QuboleOperator 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.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.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.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.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.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.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) test_hql() (airflow.hooks.hive_hooks.HiveCliHook method) TIME_TO_SLEEP_IN_SECONDS (in module airflow.contrib.hooks.gcp_compute_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) timeout (class in airflow.models) 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.XCom attribute) (airflow.models.slamiss.SlaMiss attribute) timezone (airflow.models.DagModel attribute) to_csv() (airflow.hooks.hive_hooks.HiveServer2Hook method) to_json() (airflow.models.Pool method) topological_sort() (airflow.models.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) TriggerDagRunOperator (class in airflow.operators.dagrun_operator) TriggerRule (class in airflow.models) TriggerRuleDep (class in airflow.models) try_number (airflow.models.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.mysql_to_gcs.MySqlToGoogleCloudStorageOperator class method) (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class method) (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)

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.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.BigQueryOperator 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.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.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.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.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.operators.BaseOperator attribute) (airflow.operators.subdag_operator.SubDagOperator attribute) unfinished() (airflow.models.State class method) UNIX_PATH_MAX (in module airflow.contrib.hooks.gcp_sql_hook) unixname (airflow.models.TaskInstance attribute) UNKNOWN (airflow.contrib.hooks.gcp_sql_hook.CloudSqlOperationStatus attribute) UP_FOR_RESCHEDULE (airflow.models.State attribute) UP_FOR_RETRY (airflow.models.State attribute) update_cluster() (airflow.contrib.hooks.gcp_bigtable_hook.BigtableHook static method) update_database() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook 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_instance() (airflow.contrib.hooks.gcp_spanner_hook.CloudSpannerHook 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) 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 (airflow.models.WeightRule attribute) UPSTREAM_FAILED (airflow.models.State attribute) upstream_list (airflow.models.BaseOperator attribute) (airflow.operators.BaseOperator attribute) upstream_task_ids (airflow.models.BaseOperator attribute) (airflow.operators.BaseOperator attribute) used_slots() (airflow.models.Pool method) User (class in airflow.models) USER_AGENT_HEADER (in module airflow.contrib.hooks.databricks_hook) user_id (airflow.models.Chart attribute) (airflow.models.KnownEvent attribute) username (airflow.models.User attribute) UtcDateTime (class in airflow.models) utils_date_range() (in module airflow.models)

V

val (airflow.models.Variable attribute) valid_modes (airflow.sensors.base_sensor_operator.BaseSensorOperator attribute) validate_body() (airflow.contrib.operators.gcp_transfer_operator.TransferJobValidator method) validate_key() (in module airflow.models) 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)

ValueCheckOperator (class in airflow.operators.check_operator) Variable (class in airflow.models) verify_integrity() (airflow.models.DagRun method) VerticaHook (class in airflow.contrib.hooks.vertica_hook) VerticaOperator (class in airflow.contrib.operators.vertica_operator) VerticaToHiveTransfer (class in airflow.contrib.operators.vertica_to_hive) 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) WeightRule (class in airflow.models) 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) XCom (class in airflow.models) xcom_pull() (airflow.models.BaseOperator method) (airflow.models.TaskInstance method) (airflow.operators.BaseOperator method)

xcom_push() (airflow.models.BaseOperator method) (airflow.models.TaskInstance method) (airflow.operators.BaseOperator method) XCOM_RETURN_KEY (in module airflow.models) 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)

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)