[AIRFLOW-4818] Remove valid files from pylint_todo.txt (#5439)
This commit is contained in:
Родитель
f34e13ab32
Коммит
45217d7d5f
|
@ -1,52 +1,29 @@
|
|||
./airflow/__init__.py
|
||||
./airflow/bin/__init__.py
|
||||
./airflow/bin/cli.py
|
||||
./airflow/config_templates/__init__.py
|
||||
./airflow/configuration.py
|
||||
./airflow/config_templates/airflow_local_settings.py
|
||||
./airflow/config_templates/default_celery.py
|
||||
./airflow/config_templates/default_webserver_config.py
|
||||
./airflow/configuration.py
|
||||
./airflow/contrib/__init__.py
|
||||
./airflow/contrib/auth/__init__.py
|
||||
./airflow/contrib/auth/backends/__init__.py
|
||||
./airflow/contrib/auth/backends/github_enterprise_auth.py
|
||||
./airflow/contrib/auth/backends/google_auth.py
|
||||
./airflow/contrib/auth/backends/kerberos_auth.py
|
||||
./airflow/contrib/auth/backends/ldap_auth.py
|
||||
./airflow/contrib/auth/backends/password_auth.py
|
||||
./airflow/contrib/example_dags/__init__.py
|
||||
./airflow/contrib/example_dags/example_azure_container_instances_operator.py
|
||||
./airflow/contrib/example_dags/example_azure_cosmosdb_sensor.py
|
||||
./airflow/contrib/example_dags/example_databricks_operator.py
|
||||
./airflow/contrib/example_dags/example_dingding_operator.py
|
||||
./airflow/contrib/example_dags/example_emr_job_flow_automatic_steps.py
|
||||
./airflow/contrib/example_dags/example_emr_job_flow_manual_steps.py
|
||||
./airflow/contrib/example_dags/example_gcp_bigtable_operators.py
|
||||
./airflow/contrib/example_dags/example_gcp_compute.py
|
||||
./airflow/contrib/example_dags/example_gcp_compute_igm.py
|
||||
./airflow/contrib/example_dags/example_gcp_function.py
|
||||
./airflow/contrib/example_dags/example_gcp_natural_language.py
|
||||
./airflow/contrib/example_dags/example_gcp_spanner.py
|
||||
./airflow/contrib/example_dags/example_gcp_speech.py
|
||||
./airflow/contrib/example_dags/example_gcp_sql.py
|
||||
./airflow/contrib/example_dags/example_gcp_sql_query.py
|
||||
./airflow/contrib/example_dags/example_gcp_transfer.py
|
||||
./airflow/contrib/example_dags/example_gcp_translate.py
|
||||
./airflow/contrib/example_dags/example_gcp_video_intelligence.py
|
||||
./airflow/contrib/example_dags/example_gcp_vision.py
|
||||
./airflow/contrib/example_dags/example_gcs_acl.py
|
||||
./airflow/contrib/example_dags/example_gcs_to_bq_operator.py
|
||||
./airflow/contrib/example_dags/example_kubernetes_executor.py
|
||||
./airflow/contrib/example_dags/example_kubernetes_executor_config.py
|
||||
./airflow/contrib/example_dags/example_kubernetes_operator.py
|
||||
./airflow/contrib/example_dags/example_pubsub_flow.py
|
||||
./airflow/contrib/example_dags/example_qubole_operator.py
|
||||
./airflow/contrib/example_dags/example_qubole_sensor.py
|
||||
./airflow/contrib/example_dags/example_twitter_dag.py
|
||||
./airflow/contrib/example_dags/example_winrm_operator.py
|
||||
./airflow/contrib/example_dags/libs/__init__.py
|
||||
./airflow/contrib/example_dags/libs/helper.py
|
||||
./airflow/contrib/hooks/__init__.py
|
||||
./airflow/contrib/hooks/aws_athena_hook.py
|
||||
./airflow/contrib/hooks/aws_dynamodb_hook.py
|
||||
./airflow/contrib/hooks/aws_firehose_hook.py
|
||||
|
@ -118,12 +95,11 @@
|
|||
./airflow/contrib/hooks/vertica_hook.py
|
||||
./airflow/contrib/hooks/wasb_hook.py
|
||||
./airflow/contrib/hooks/winrm_hook.py
|
||||
./airflow/contrib/operators/__init__.py
|
||||
./airflow/contrib/operators/adls_list_operator.py
|
||||
./airflow/contrib/operators/adls_to_gcs.py
|
||||
./airflow/contrib/operators/awsbatch_operator.py
|
||||
./airflow/contrib/operators/aws_athena_operator.py
|
||||
./airflow/contrib/operators/aws_sqs_publish_operator.py
|
||||
./airflow/contrib/operators/awsbatch_operator.py
|
||||
./airflow/contrib/operators/azure_container_instances_operator.py
|
||||
./airflow/contrib/operators/azure_cosmos_operator.py
|
||||
./airflow/contrib/operators/cassandra_to_gcs.py
|
||||
|
@ -187,7 +163,6 @@
|
|||
./airflow/contrib/operators/wasb_delete_blob_operator.py
|
||||
./airflow/contrib/operators/winrm_operator.py
|
||||
./airflow/contrib/plugins/metastore_browser/main.py
|
||||
./airflow/contrib/sensors/__init__.py
|
||||
./airflow/contrib/sensors/aws_athena_sensor.py
|
||||
./airflow/contrib/sensors/aws_glue_catalog_partition_sensor.py
|
||||
./airflow/contrib/sensors/aws_redshift_cluster_sensor.py
|
||||
|
@ -219,26 +194,22 @@
|
|||
./airflow/contrib/sensors/sftp_sensor.py
|
||||
./airflow/contrib/sensors/wasb_sensor.py
|
||||
./airflow/contrib/sensors/weekday_sensor.py
|
||||
./airflow/contrib/task_runner/__init__.py
|
||||
./airflow/contrib/task_runner/cgroup_task_runner.py
|
||||
./airflow/contrib/utils/__init__.py
|
||||
./airflow/contrib/utils/gcp_field_sanitizer.py
|
||||
./airflow/contrib/utils/gcp_field_validator.py
|
||||
./airflow/contrib/utils/log/__init__.py
|
||||
./airflow/contrib/utils/log/task_handler_with_custom_formatter.py
|
||||
./airflow/contrib/utils/mlengine_operator_utils.py
|
||||
./airflow/contrib/utils/mlengine_prediction_summary.py
|
||||
./airflow/contrib/utils/sendgrid.py
|
||||
./airflow/contrib/utils/weekday.py
|
||||
./airflow/exceptions.py
|
||||
./airflow/executors/__init__.py
|
||||
./airflow/executors/base_executor.py
|
||||
./airflow/executors/celery_executor.py
|
||||
./airflow/executors/dask_executor.py
|
||||
./airflow/executors/kubernetes_executor.py
|
||||
./airflow/executors/local_executor.py
|
||||
./airflow/executors/sequential_executor.py
|
||||
./airflow/hooks/__init__.py
|
||||
./airflow/executors/__init__.py
|
||||
./airflow/hooks/base_hook.py
|
||||
./airflow/hooks/dbapi_hook.py
|
||||
./airflow/hooks/docker_hook.py
|
||||
|
@ -259,16 +230,15 @@
|
|||
./airflow/hooks/sqlite_hook.py
|
||||
./airflow/hooks/webhdfs_hook.py
|
||||
./airflow/hooks/zendesk_hook.py
|
||||
./airflow/jobs/__init__.py
|
||||
./airflow/hooks/__init__.py
|
||||
./airflow/jobs/backfill_job.py
|
||||
./airflow/jobs/base_job.py
|
||||
./airflow/jobs/local_task_job.py
|
||||
./airflow/jobs/scheduler_job.py
|
||||
./airflow/kubernetes/__init__.py
|
||||
./airflow/kubernetes/kube_client.py
|
||||
./airflow/kubernetes/kubernetes_request_factory/__init__.py
|
||||
./airflow/jobs/__init__.py
|
||||
./airflow/kubernetes/kubernetes_request_factory/kubernetes_request_factory.py
|
||||
./airflow/kubernetes/kubernetes_request_factory/pod_request_factory.py
|
||||
./airflow/kubernetes/kube_client.py
|
||||
./airflow/kubernetes/pod.py
|
||||
./airflow/kubernetes/pod_generator.py
|
||||
./airflow/kubernetes/pod_launcher.py
|
||||
|
@ -276,16 +246,16 @@
|
|||
./airflow/kubernetes/volume.py
|
||||
./airflow/kubernetes/volume_mount.py
|
||||
./airflow/kubernetes/worker_configuration.py
|
||||
./airflow/lineage/__init__.py
|
||||
./airflow/lineage/backend/__init__.py
|
||||
./airflow/lineage/backend/atlas/__init__.py
|
||||
./airflow/lineage/backend/atlas/typedefs.py
|
||||
./airflow/lineage/backend/atlas/__init__.py
|
||||
./airflow/lineage/backend/__init__.py
|
||||
./airflow/lineage/datasets.py
|
||||
./airflow/lineage/__init__.py
|
||||
./airflow/logging_config.py
|
||||
./airflow/macros/__init__.py
|
||||
./airflow/macros/hive.py
|
||||
./airflow/migrations/__init__.py
|
||||
./airflow/macros/__init__.py
|
||||
./airflow/migrations/env.py
|
||||
./airflow/migrations/versions/004c1210f153_increase_queue_name_size_limit.py
|
||||
./airflow/migrations/versions/03bc53e68815_add_sm_dag_index.py
|
||||
./airflow/migrations/versions/05f30312d566_merge_heads.py
|
||||
./airflow/migrations/versions/0a2a5b66e19d_add_task_reschedule_table.py
|
||||
|
@ -317,7 +287,6 @@
|
|||
./airflow/migrations/versions/939bb1e647c8_task_reschedule_fk_on_cascade_delete.py
|
||||
./airflow/migrations/versions/947454bf1dff_add_ti_job_id_index.py
|
||||
./airflow/migrations/versions/9635ae0956e7_index_faskfail.py
|
||||
./airflow/migrations/versions/__init__.py
|
||||
./airflow/migrations/versions/a56c9515abdc_remove_dag_stat_table.py
|
||||
./airflow/migrations/versions/bba5a7cfc896_add_a_column_to_track_the_encryption_.py
|
||||
./airflow/migrations/versions/bbc73705a13e_add_notification_sent_column_to_sla_miss.py
|
||||
|
@ -332,8 +301,6 @@
|
|||
./airflow/migrations/versions/e3a246e0dc1_current_schema.py
|
||||
./airflow/migrations/versions/f23433877c24_fix_mysql_not_null_constraint.py
|
||||
./airflow/migrations/versions/f2ca10b85618_add_dag_stats_table.py
|
||||
./airflow/migrations/versions/004c1210f153_increase_queue_name_size_limit.py
|
||||
./airflow/models/__init__.py
|
||||
./airflow/models/base.py
|
||||
./airflow/models/baseoperator.py
|
||||
./airflow/models/connection.py
|
||||
|
@ -353,7 +320,7 @@
|
|||
./airflow/models/taskreschedule.py
|
||||
./airflow/models/variable.py
|
||||
./airflow/models/xcom.py
|
||||
./airflow/operators/__init__.py
|
||||
./airflow/models/__init__.py
|
||||
./airflow/operators/bash_operator.py
|
||||
./airflow/operators/check_operator.py
|
||||
./airflow/operators/dagrun_operator.py
|
||||
|
@ -388,11 +355,10 @@
|
|||
./airflow/operators/slack_operator.py
|
||||
./airflow/operators/sqlite_operator.py
|
||||
./airflow/operators/subdag_operator.py
|
||||
./airflow/operators/__init__.py
|
||||
./airflow/plugins_manager.py
|
||||
./airflow/security/__init__.py
|
||||
./airflow/security/kerberos.py
|
||||
./airflow/security/utils.py
|
||||
./airflow/sensors/__init__.py
|
||||
./airflow/sensors/base_sensor_operator.py
|
||||
./airflow/sensors/external_task_sensor.py
|
||||
./airflow/sensors/hdfs_sensor.py
|
||||
|
@ -406,19 +372,16 @@
|
|||
./airflow/sensors/time_delta_sensor.py
|
||||
./airflow/sensors/time_sensor.py
|
||||
./airflow/sensors/web_hdfs_sensor.py
|
||||
./airflow/sensors/__init__.py
|
||||
./airflow/settings.py
|
||||
./airflow/stats.py
|
||||
./airflow/task/__init__.py
|
||||
./airflow/task/task_runner/__init__.py
|
||||
./airflow/task/task_runner/base_task_runner.py
|
||||
./airflow/task/task_runner/standard_task_runner.py
|
||||
./airflow/ti_deps/__init__.py
|
||||
./airflow/ti_deps/dep_context.py
|
||||
./airflow/ti_deps/deps/__init__.py
|
||||
./airflow/task/task_runner/__init__.py
|
||||
./airflow/ti_deps/deps/base_ti_dep.py
|
||||
./airflow/ti_deps/deps/dagrun_exists_dep.py
|
||||
./airflow/ti_deps/deps/dag_ti_slots_available_dep.py
|
||||
./airflow/ti_deps/deps/dag_unpaused_dep.py
|
||||
./airflow/ti_deps/deps/dagrun_exists_dep.py
|
||||
./airflow/ti_deps/deps/exec_date_after_start_date_dep.py
|
||||
./airflow/ti_deps/deps/not_in_retry_period_dep.py
|
||||
./airflow/ti_deps/deps/not_running_dep.py
|
||||
|
@ -429,9 +392,8 @@
|
|||
./airflow/ti_deps/deps/task_concurrency_dep.py
|
||||
./airflow/ti_deps/deps/trigger_rule_dep.py
|
||||
./airflow/ti_deps/deps/valid_state_dep.py
|
||||
./airflow/utils/__init__.py
|
||||
./airflow/ti_deps/dep_context.py
|
||||
./airflow/utils/asciiart.py
|
||||
./airflow/utils/cli.py
|
||||
./airflow/utils/cli_action_loggers.py
|
||||
./airflow/utils/compression.py
|
||||
./airflow/utils/configuration.py
|
||||
|
@ -443,7 +405,6 @@
|
|||
./airflow/utils/file.py
|
||||
./airflow/utils/helpers.py
|
||||
./airflow/utils/json.py
|
||||
./airflow/utils/log/__init__.py
|
||||
./airflow/utils/log/es_task_handler.py
|
||||
./airflow/utils/log/file_processor_handler.py
|
||||
./airflow/utils/log/file_task_handler.py
|
||||
|
@ -463,9 +424,6 @@
|
|||
./airflow/utils/trigger_rule.py
|
||||
./airflow/utils/weight_rule.py
|
||||
./airflow/version.py
|
||||
./airflow/www/__init__.py
|
||||
./airflow/www/api/__init__.py
|
||||
./airflow/www/api/experimental/__init__.py
|
||||
./airflow/www/api/experimental/endpoints.py
|
||||
./airflow/www/app.py
|
||||
./airflow/www/blueprints.py
|
||||
|
@ -478,72 +436,46 @@
|
|||
./airflow/www/validators.py
|
||||
./airflow/www/views.py
|
||||
./airflow/www/widgets.py
|
||||
./airflow/__init__.py
|
||||
./dags/test_dag.py
|
||||
./docs/conf.py
|
||||
./docs/exts/__init__.py
|
||||
./docs/exts/docroles.py
|
||||
./docs/exts/exampleinclude.py
|
||||
./docs/exts/removemarktransform.py
|
||||
./scripts/perf/dags/perf_dag_1.py
|
||||
./scripts/perf/dags/perf_dag_2.py
|
||||
./scripts/perf/scheduler_ops_metrics.py
|
||||
./tests/__init__.py
|
||||
./tests/api/__init__.py
|
||||
./tests/api/client/__init__.py
|
||||
./tests/api/client/test_local_client.py
|
||||
./tests/api/common/__init__.py
|
||||
./tests/api/common/experimental/__init__.py
|
||||
./tests/api/common/experimental/test_delete_dag.py
|
||||
./tests/api/common/experimental/test_mark_tasks.py
|
||||
./tests/api/common/experimental/test_pool.py
|
||||
./tests/api/common/experimental/test_trigger_dag.py
|
||||
./tests/cli/__init__.py
|
||||
./tests/cli/test_cli.py
|
||||
./tests/cli/test_worker_initialisation.py
|
||||
./tests/compat.py
|
||||
./tests/contrib/__init__.py
|
||||
./tests/contrib/hooks/__init__.py
|
||||
./tests/contrib/hooks/test_aws_dynamodb_hook.py
|
||||
./tests/contrib/hooks/test_aws_firehose_hook.py
|
||||
./tests/contrib/hooks/test_aws_glue_catalog_hook.py
|
||||
./tests/contrib/hooks/test_aws_hook.py
|
||||
./tests/contrib/hooks/test_aws_lambda_hook.py
|
||||
./tests/contrib/hooks/test_aws_sns_hook.py
|
||||
./tests/contrib/hooks/test_aws_sqs_hook.py
|
||||
./tests/contrib/hooks/test_azure_container_instance_hook.py
|
||||
./tests/contrib/hooks/test_azure_container_registry_hook.py
|
||||
./tests/contrib/hooks/test_azure_container_volume_hook.py
|
||||
./tests/contrib/hooks/test_azure_cosmos_hook.py
|
||||
./tests/contrib/hooks/test_azure_data_lake_hook.py
|
||||
./tests/contrib/hooks/test_azure_fileshare_hook.py
|
||||
./tests/contrib/hooks/test_bigquery_hook.py
|
||||
./tests/contrib/hooks/test_cassandra_hook.py
|
||||
./tests/contrib/hooks/test_cloudant_hook.py
|
||||
./tests/contrib/hooks/test_databricks_hook.py
|
||||
./tests/contrib/hooks/test_datadog_hook.py
|
||||
./tests/contrib/hooks/test_datastore_hook.py
|
||||
./tests/contrib/hooks/test_dingding_hook.py
|
||||
./tests/contrib/hooks/test_discord_webhook_hook.py
|
||||
./tests/contrib/hooks/test_emr_hook.py
|
||||
./tests/contrib/hooks/test_ftp_hook.py
|
||||
./tests/contrib/hooks/test_gcp_api_base_hook.py
|
||||
./tests/contrib/hooks/test_gcp_bigtable_hook.py
|
||||
./tests/contrib/hooks/test_gcp_compute_hook.py
|
||||
./tests/contrib/hooks/test_gcp_container_hook.py
|
||||
./tests/contrib/hooks/test_gcp_dataflow_hook.py
|
||||
./tests/contrib/hooks/test_gcp_dataproc_hook.py
|
||||
./tests/contrib/hooks/test_gcp_function_hook.py
|
||||
./tests/contrib/hooks/test_gcp_kms_hook.py
|
||||
./tests/contrib/hooks/test_gcp_mlengine_hook.py
|
||||
./tests/contrib/hooks/test_gcp_natural_language_hook.py
|
||||
./tests/contrib/hooks/test_gcp_pubsub_hook.py
|
||||
./tests/contrib/hooks/test_gcp_spanner_hook.py
|
||||
./tests/contrib/hooks/test_gcp_speech_to_text_hook.py
|
||||
./tests/contrib/hooks/test_gcp_sql_hook.py
|
||||
./tests/contrib/hooks/test_gcp_text_to_speech_hook.py
|
||||
./tests/contrib/hooks/test_gcp_transfer_hook.py
|
||||
./tests/contrib/hooks/test_gcp_translate_hook.py
|
||||
./tests/contrib/hooks/test_gcp_video_intelligence_hook.py
|
||||
./tests/contrib/hooks/test_gcp_vision_hook.py
|
||||
./tests/contrib/hooks/test_gcs_hook.py
|
||||
./tests/contrib/hooks/test_grpc_hook.py
|
||||
|
@ -553,9 +485,6 @@
|
|||
./tests/contrib/hooks/test_mongo_hook.py
|
||||
./tests/contrib/hooks/test_openfaas_hook.py
|
||||
./tests/contrib/hooks/test_opsgenie_alert_hook.py
|
||||
./tests/contrib/hooks/test_pinot_hook.py
|
||||
./tests/contrib/hooks/test_qubole_check_hook.py
|
||||
./tests/contrib/hooks/test_redis_hook.py
|
||||
./tests/contrib/hooks/test_redshift_hook.py
|
||||
./tests/contrib/hooks/test_sagemaker_hook.py
|
||||
./tests/contrib/hooks/test_salesforce_hook.py
|
||||
|
@ -563,20 +492,15 @@
|
|||
./tests/contrib/hooks/test_sftp_hook.py
|
||||
./tests/contrib/hooks/test_slack_webhook_hook.py
|
||||
./tests/contrib/hooks/test_snowflake_hook.py
|
||||
./tests/contrib/hooks/test_spark_jdbc_hook.py
|
||||
./tests/contrib/hooks/test_spark_sql_hook.py
|
||||
./tests/contrib/hooks/test_spark_submit_hook.py
|
||||
./tests/contrib/hooks/test_sqoop_hook.py
|
||||
./tests/contrib/hooks/test_ssh_hook.py
|
||||
./tests/contrib/hooks/test_wasb_hook.py
|
||||
./tests/contrib/hooks/test_winrm_hook.py
|
||||
./tests/contrib/hooks/test_zendesk_hook.py
|
||||
./tests/contrib/operators/__init__.py
|
||||
./tests/contrib/operators/test_adls_list_operator.py
|
||||
./tests/contrib/operators/test_adls_to_gcs_operator.py
|
||||
./tests/contrib/operators/test_aws_athena_operator.py
|
||||
./tests/contrib/operators/test_aws_sqs_publish_operator.py
|
||||
./tests/contrib/operators/test_awsbatch_operator.py
|
||||
./tests/contrib/operators/test_azure_container_instances_operator.py
|
||||
./tests/contrib/operators/test_azure_cosmos_insertdocument_operator.py
|
||||
./tests/contrib/operators/test_bigquery_operator.py
|
||||
|
@ -584,81 +508,42 @@
|
|||
./tests/contrib/operators/test_databricks_operator.py
|
||||
./tests/contrib/operators/test_dataflow_operator.py
|
||||
./tests/contrib/operators/test_dataproc_operator.py
|
||||
./tests/contrib/operators/test_dingding_operator.py
|
||||
./tests/contrib/operators/test_discord_webhook_operator.py
|
||||
./tests/contrib/operators/test_druid_operator.py
|
||||
./tests/contrib/operators/test_ecs_operator.py
|
||||
./tests/contrib/operators/test_emr_add_steps_operator.py
|
||||
./tests/contrib/operators/test_emr_create_job_flow_operator.py
|
||||
./tests/contrib/operators/test_emr_terminate_job_flow_operator.py
|
||||
./tests/contrib/operators/test_file_to_gcs.py
|
||||
./tests/contrib/operators/test_file_to_wasb.py
|
||||
./tests/contrib/operators/test_gcp_bigtable_operator.py
|
||||
./tests/contrib/operators/test_gcp_bigtable_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_bigtable_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_compute_operator.py
|
||||
./tests/contrib/operators/test_gcp_compute_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_compute_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_container_operator.py
|
||||
./tests/contrib/operators/test_gcp_function_operator.py
|
||||
./tests/contrib/operators/test_gcp_function_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_natural_language_operator.py
|
||||
./tests/contrib/operators/test_gcp_natural_language_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_spanner_operator.py
|
||||
./tests/contrib/operators/test_gcp_spanner_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_spanner_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_speech_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_speech_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_speech_to_text_operator.py
|
||||
./tests/contrib/operators/test_gcp_sql_operator.py
|
||||
./tests/contrib/operators/test_gcp_sql_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_sql_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_sql_operatorquery_system.py
|
||||
./tests/contrib/operators/test_gcp_sql_operatorquery_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_text_to_speech_operator.py
|
||||
./tests/contrib/operators/test_gcp_sql_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_transfer_operator.py
|
||||
./tests/contrib/operators/test_gcp_transfer_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_transfer_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_translate_operator.py
|
||||
./tests/contrib/operators/test_gcp_translate_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_translate_speech_operator.py
|
||||
./tests/contrib/operators/test_gcp_video_intelligence_operator.py
|
||||
./tests/contrib/operators/test_gcp_video_intelligence_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_video_intelligence_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcp_vision_operator.py
|
||||
./tests/contrib/operators/test_gcp_vision_operator_system.py
|
||||
./tests/contrib/operators/test_gcp_vision_operator_system_helper.py
|
||||
./tests/contrib/operators/test_gcs_acl_operator.py
|
||||
./tests/contrib/operators/test_gcs_acl_operator_system.py
|
||||
./tests/contrib/operators/test_gcs_delete_operator.py
|
||||
./tests/contrib/operators/test_gcs_download_operator.py
|
||||
./tests/contrib/operators/test_gcs_list_operator.py
|
||||
./tests/contrib/operators/test_gcs_operator.py
|
||||
./tests/contrib/operators/test_gcs_to_s3_operator.py
|
||||
./tests/contrib/operators/test_grpc_operator.py
|
||||
./tests/contrib/operators/test_hipchat_operator.py
|
||||
./tests/contrib/operators/test_hive_to_dynamodb_operator.py
|
||||
./tests/contrib/operators/test_imap_attachment_to_s3_operator.py
|
||||
./tests/contrib/operators/test_jenkins_operator.py
|
||||
./tests/contrib/operators/test_jira_operator_test.py
|
||||
./tests/contrib/operators/test_mlengine_operator.py
|
||||
./tests/contrib/operators/test_mongo_to_s3_operator.py
|
||||
./tests/contrib/operators/test_mssql_to_gcs_operator.py
|
||||
./tests/contrib/operators/test_mysql_to_gcs_operator.py
|
||||
./tests/contrib/operators/test_opsgenie_alert_operator.py
|
||||
./tests/contrib/operators/test_oracle_to_azure_data_lake_transfer.py
|
||||
./tests/contrib/operators/test_oracle_to_oracle_transfer.py
|
||||
./tests/contrib/operators/test_postgres_to_gcs_operator.py
|
||||
./tests/contrib/operators/test_pubsub_operator.py
|
||||
./tests/contrib/operators/test_qubole_check_operator.py
|
||||
./tests/contrib/operators/test_qubole_operator.py
|
||||
./tests/contrib/operators/test_redis_publish_operator.py
|
||||
./tests/contrib/operators/test_s3_copy_object_operator.py
|
||||
./tests/contrib/operators/test_s3_delete_objects_operator.py
|
||||
./tests/contrib/operators/test_s3_list_operator.py
|
||||
./tests/contrib/operators/test_s3_to_gcs_operator.py
|
||||
./tests/contrib/operators/test_s3_to_sftp_operator.py
|
||||
./tests/contrib/operators/test_sagemaker_base_operator.py
|
||||
./tests/contrib/operators/test_sagemaker_endpoint_config_operator.py
|
||||
./tests/contrib/operators/test_sagemaker_endpoint_operator.py
|
||||
./tests/contrib/operators/test_sagemaker_model_operator.py
|
||||
|
@ -667,55 +552,32 @@
|
|||
./tests/contrib/operators/test_sagemaker_tuning_operator.py
|
||||
./tests/contrib/operators/test_segment_track_event_operator.py
|
||||
./tests/contrib/operators/test_sftp_operator.py
|
||||
./tests/contrib/operators/test_sftp_to_s3_operator.py
|
||||
./tests/contrib/operators/test_slack_webhook_operator.py
|
||||
./tests/contrib/operators/test_snowflake_operator.py
|
||||
./tests/contrib/operators/test_sns_publish_operator.py
|
||||
./tests/contrib/operators/test_spark_jdbc_operator.py
|
||||
./tests/contrib/operators/test_spark_sql_operator.py
|
||||
./tests/contrib/operators/test_spark_submit_operator.py
|
||||
./tests/contrib/operators/test_sqoop_operator.py
|
||||
./tests/contrib/operators/test_ssh_operator.py
|
||||
./tests/contrib/operators/test_vertica_operator.py
|
||||
./tests/contrib/operators/test_vertica_to_mysql.py
|
||||
./tests/contrib/operators/test_wasb_delete_blob_operator.py
|
||||
./tests/contrib/operators/test_winrm_operator.py
|
||||
./tests/contrib/sensors/__init__.py
|
||||
./tests/contrib/sensors/test_athena_sensor.py
|
||||
./tests/contrib/sensors/test_aws_glue_catalog_partition_sensor.py
|
||||
./tests/contrib/sensors/test_aws_redshift_cluster_sensor.py
|
||||
./tests/contrib/sensors/test_bash_sensor.py
|
||||
./tests/contrib/sensors/test_cassandra_sensor.py
|
||||
./tests/contrib/sensors/test_celery_queue_sensor.py
|
||||
./tests/contrib/sensors/test_datadog_sensor.py
|
||||
./tests/contrib/sensors/test_emr_base_sensor.py
|
||||
./tests/contrib/sensors/test_emr_job_flow_sensor.py
|
||||
./tests/contrib/sensors/test_emr_step_sensor.py
|
||||
./tests/contrib/sensors/test_file_sensor.py
|
||||
./tests/contrib/sensors/test_ftp_sensor.py
|
||||
./tests/contrib/sensors/test_gcp_transfer_sensor.py
|
||||
./tests/contrib/sensors/test_gcs_upload_session_sensor.py
|
||||
./tests/contrib/sensors/test_hdfs_sensor.py
|
||||
./tests/contrib/sensors/test_imap_attachment_sensor.py
|
||||
./tests/contrib/sensors/test_jira_sensor_test.py
|
||||
./tests/contrib/sensors/test_mongo_sensor.py
|
||||
./tests/contrib/sensors/test_pubsub_sensor.py
|
||||
./tests/contrib/sensors/test_python_sensor.py
|
||||
./tests/contrib/sensors/test_qubole_sensor.py
|
||||
./tests/contrib/sensors/test_redis_pub_sub_sensor.py
|
||||
./tests/contrib/sensors/test_redis_sensor.py
|
||||
./tests/contrib/sensors/test_sagemaker_base_sensor.py
|
||||
./tests/contrib/sensors/test_sagemaker_endpoint_sensor.py
|
||||
./tests/contrib/sensors/test_sagemaker_training_sensor.py
|
||||
./tests/contrib/sensors/test_sagemaker_transform_sensor.py
|
||||
./tests/contrib/sensors/test_sagemaker_tuning_sensor.py
|
||||
./tests/contrib/sensors/test_sftp_sensor.py
|
||||
./tests/contrib/sensors/test_sqs_sensor.py
|
||||
./tests/contrib/sensors/test_wasb_sensor.py
|
||||
./tests/contrib/sensors/test_weekday_sensor.py
|
||||
./tests/contrib/task_runner/__init__.py
|
||||
./tests/contrib/task_runner/test_cgroup_task_runner.py
|
||||
./tests/contrib/utils/__init__.py
|
||||
./tests/contrib/utils/base_gcp_mock.py
|
||||
./tests/contrib/utils/base_gcp_system_test_case.py
|
||||
./tests/contrib/utils/gcp_authenticator.py
|
||||
|
@ -723,31 +585,17 @@
|
|||
./tests/contrib/utils/run_once_decorator.py
|
||||
./tests/contrib/utils/test_mlengine_operator_utils.py
|
||||
./tests/contrib/utils/test_sendgrid.py
|
||||
./tests/contrib/utils/test_task_handler_with_custom_formatter.py
|
||||
./tests/contrib/utils/test_weekday.py
|
||||
./tests/core.py
|
||||
./tests/dags/no_dags.py
|
||||
./tests/dags/test_backfill_pooled_tasks.py
|
||||
./tests/dags/test_cli_triggered_dags.py
|
||||
./tests/dags/test_default_impersonation.py
|
||||
./tests/dags/test_double_trigger.py
|
||||
./tests/dags/test_example_bash_operator.py
|
||||
./tests/dags/test_impersonation.py
|
||||
./tests/dags/test_impersonation_custom.py
|
||||
./tests/dags/test_impersonation_subdag.py
|
||||
./tests/dags/test_invalid_cron.py
|
||||
./tests/dags/test_issue_1225.py
|
||||
./tests/dags/test_latest_runs.py
|
||||
./tests/dags/test_mark_success.py
|
||||
./tests/dags/test_no_impersonation.py
|
||||
./tests/dags/test_on_kill.py
|
||||
./tests/dags/test_retry_handling_job.py
|
||||
./tests/dags/test_scheduler_dags.py
|
||||
./tests/dags/test_task_view_type_check.py
|
||||
./tests/dags_with_system_exit/a_system_exit.py
|
||||
./tests/dags_with_system_exit/b_test_scheduler_dags.py
|
||||
./tests/dags_with_system_exit/c_system_exit.py
|
||||
./tests/executors/__init__.py
|
||||
./tests/executors/test_base_executor.py
|
||||
./tests/executors/test_celery_executor.py
|
||||
./tests/executors/test_dask_executor.py
|
||||
|
@ -755,86 +603,57 @@
|
|||
./tests/executors/test_kubernetes_executor.py
|
||||
./tests/executors/test_local_executor.py
|
||||
./tests/executors/test_sequential_executor.py
|
||||
./tests/hooks/__init__.py
|
||||
./tests/hooks/test_dbapi_hook.py
|
||||
./tests/hooks/test_docker_hook.py
|
||||
./tests/hooks/test_druid_hook.py
|
||||
./tests/hooks/test_gcp_sql_hook.py
|
||||
./tests/hooks/test_hive_hook.py
|
||||
./tests/hooks/test_http_hook.py
|
||||
./tests/hooks/test_mysql_hook.py
|
||||
./tests/hooks/test_oracle_hook.py
|
||||
./tests/hooks/test_pig_hook.py
|
||||
./tests/hooks/test_postgres_hook.py
|
||||
./tests/hooks/test_presto_hook.py
|
||||
./tests/hooks/test_s3_hook.py
|
||||
./tests/hooks/test_slack_hook.py
|
||||
./tests/hooks/test_webhdfs_hook.py
|
||||
./tests/jobs/__init__.py
|
||||
./tests/jobs/test_backfill_job.py
|
||||
./tests/jobs/test_base_job.py
|
||||
./tests/jobs/test_local_task_job.py
|
||||
./tests/jobs/test_scheduler_job.py
|
||||
./tests/kubernetes/__init__.py
|
||||
./tests/kubernetes/kubernetes_request_factory/__init__.py
|
||||
./tests/kubernetes/kubernetes_request_factory/test_kubernetes_request_factory.py
|
||||
./tests/kubernetes/kubernetes_request_factory/test_pod_request_factory.py
|
||||
./tests/kubernetes/test_pod_launcher.py
|
||||
./tests/lineage/__init__.py
|
||||
./tests/lineage/backend/__init__.py
|
||||
./tests/lineage/backend/test_atlas.py
|
||||
./tests/lineage/test_lineage.py
|
||||
./tests/macros/__init__.py
|
||||
./tests/macros/test_hive.py
|
||||
./tests/minikube/__init__.py
|
||||
./tests/minikube/test_kubernetes_executor.py
|
||||
./tests/minikube/test_kubernetes_pod_operator.py
|
||||
./tests/models/__init__.py
|
||||
./tests/models/test_cleartasks.py
|
||||
./tests/models/test_connection.py
|
||||
./tests/models/test_dag.py
|
||||
./tests/models/test_dagbag.py
|
||||
./tests/models/test_dagrun.py
|
||||
./tests/models/test_kubernetes.py
|
||||
./tests/models/test_pool.py
|
||||
./tests/models/test_skipmixin.py
|
||||
./tests/models/test_taskinstance.py
|
||||
./tests/models/test_variable.py
|
||||
./tests/operators/__init__.py
|
||||
./tests/operators/test_bash_operator.py
|
||||
./tests/operators/test_check_operator.py
|
||||
./tests/operators/test_docker_operator.py
|
||||
./tests/operators/test_druid_check_operator.py
|
||||
./tests/operators/test_email_operator.py
|
||||
./tests/operators/test_hive_operator.py
|
||||
./tests/operators/test_hive_stats_operator.py
|
||||
./tests/operators/test_hive_to_druid.py
|
||||
./tests/operators/test_hive_to_mysql.py
|
||||
./tests/operators/test_hive_to_samba_operator.py
|
||||
./tests/operators/test_http_operator.py
|
||||
./tests/operators/test_jdbc_operator.py
|
||||
./tests/operators/test_latest_only_operator.py
|
||||
./tests/operators/test_mssql_to_hive.py
|
||||
./tests/operators/test_operators.py
|
||||
./tests/operators/test_papermill_operator.py
|
||||
./tests/operators/test_presto_to_mysql.py
|
||||
./tests/operators/test_python_operator.py
|
||||
./tests/operators/test_redshift_to_s3_operator.py
|
||||
./tests/operators/test_s3_file_transform_operator.py
|
||||
./tests/operators/test_s3_to_hive_operator.py
|
||||
./tests/operators/test_s3_to_redshift_operator.py
|
||||
./tests/operators/test_slack_operator.py
|
||||
./tests/operators/test_subdag_operator.py
|
||||
./tests/operators/test_virtualenv_operator.py
|
||||
./tests/plugins/__init__.py
|
||||
./tests/plugins/test_plugin.py
|
||||
./tests/plugins/test_plugins_manager.py
|
||||
./tests/security/__init__.py
|
||||
./tests/security/test_kerberos.py
|
||||
./tests/sensors/__init__.py
|
||||
./tests/sensors/test_base_sensor.py
|
||||
./tests/sensors/test_external_task_sensor.py
|
||||
./tests/sensors/test_hdfs_sensor.py
|
||||
./tests/sensors/test_http_sensor.py
|
||||
./tests/sensors/test_named_hive_partition_sensor.py
|
||||
./tests/sensors/test_s3_key_sensor.py
|
||||
|
@ -842,40 +661,26 @@
|
|||
./tests/sensors/test_sql_sensor.py
|
||||
./tests/sensors/test_timedelta_sensor.py
|
||||
./tests/sensors/test_timeout_sensor.py
|
||||
./tests/task/__init__.py
|
||||
./tests/task/task_runner/__init__.py
|
||||
./tests/task/task_runner/test_standard_task_runner.py
|
||||
./tests/task/__init__.py
|
||||
./tests/test_configuration.py
|
||||
./tests/test_impersonation.py
|
||||
./tests/test_logging_config.py
|
||||
./tests/test_local_settings.py
|
||||
./tests/test_logging_config.py
|
||||
./tests/test_stats.py
|
||||
./tests/test_utils/__init__.py
|
||||
./tests/test_utils/db.py
|
||||
./tests/test_utils/decorators.py
|
||||
./tests/test_utils/fake_datetime.py
|
||||
./tests/test_utils/reset_warning_registry.py
|
||||
./tests/ti_deps/__init__.py
|
||||
./tests/ti_deps/contexts/__init__.py
|
||||
./tests/ti_deps/deps/__init__.py
|
||||
./tests/ti_deps/deps/fake_models.py
|
||||
./tests/ti_deps/deps/test_dag_ti_slots_available_dep.py
|
||||
./tests/ti_deps/deps/test_dag_unpaused_dep.py
|
||||
./tests/ti_deps/deps/test_dagrun_exists_dep.py
|
||||
./tests/ti_deps/deps/test_not_in_retry_period_dep.py
|
||||
./tests/ti_deps/deps/test_not_running_dep.py
|
||||
./tests/ti_deps/deps/test_not_skipped_dep.py
|
||||
./tests/ti_deps/deps/test_prev_dagrun_dep.py
|
||||
./tests/ti_deps/deps/test_ready_to_reschedule_dep.py
|
||||
./tests/ti_deps/deps/test_runnable_exec_date_dep.py
|
||||
./tests/ti_deps/deps/test_task_concurrency.py
|
||||
./tests/ti_deps/deps/test_trigger_rule_dep.py
|
||||
./tests/ti_deps/deps/test_valid_state_dep.py
|
||||
./tests/utils/__init__.py
|
||||
./tests/utils/log/__init__.py
|
||||
./tests/utils/log/elasticmock/__init__.py
|
||||
./tests/utils/log/elasticmock/fake_elasticsearch.py
|
||||
./tests/utils/log/elasticmock/utilities/__init__.py
|
||||
./tests/utils/log/elasticmock/__init__.py
|
||||
./tests/utils/log/test_es_task_handler.py
|
||||
./tests/utils/log/test_file_processor_handler.py
|
||||
./tests/utils/log/test_s3_task_handler.py
|
||||
|
@ -885,23 +690,14 @@
|
|||
./tests/utils/test_dates.py
|
||||
./tests/utils/test_db.py
|
||||
./tests/utils/test_decorators.py
|
||||
./tests/utils/test_email.py
|
||||
./tests/utils/test_helpers.py
|
||||
./tests/utils/test_json.py
|
||||
./tests/utils/test_log_handlers.py
|
||||
./tests/utils/test_logging_mixin.py
|
||||
./tests/utils/test_log_handlers.py
|
||||
./tests/utils/test_module_loading.py
|
||||
./tests/utils/test_net.py
|
||||
./tests/utils/test_operator_helpers.py
|
||||
./tests/utils/test_sqlalchemy.py
|
||||
./tests/utils/test_tests.py
|
||||
./tests/utils/test_timezone.py
|
||||
./tests/utils/test_trigger_rule.py
|
||||
./tests/utils/test_weight_rule.py
|
||||
./tests/www/__init__.py
|
||||
./tests/www/api/__init__.py
|
||||
./tests/www/api/experimental/__init__.py
|
||||
./tests/www/api/experimental/test_dag_runs_endpoint.py
|
||||
./tests/www/api/experimental/test_endpoints.py
|
||||
./tests/www/api/experimental/test_kerberos_endpoints.py
|
||||
./tests/www/test_security.py
|
||||
|
|
Загрузка…
Ссылка в новой задаче