Home / apache / airflow
Repository Analysis

apache/airflow

Apache Airflow - A platform to programmatically author, schedule, and monitor workflows

23.6 Moderate AI signal View on GitHub
23.6
Adjusted Score
23.6
Raw Score
100%
Time Factor
2026-05-30
Last Push
45,602
Stars
Python
Language
1,837,591
Lines of Code
9683
Files
37860
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 234HIGH 867MEDIUM 786LOW 35973

Pattern Findings

37860 matches across 20 categories. Click a row to expand file-level details.

Hyper-Verbose Identifiers19709 hits · 18218 pts
SeverityFileLineSnippet
LOWclients/python/README.md297def get_airflow_client_access_token(
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py73def _copy_elasticsearch_files(tmp_dir):
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py99def _setup_elasticsearch_integration(dot_env_file, tmp_dir):
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py114def _setup_opensearch_integration(dot_env_file, tmp_dir):
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py145def _write_providers_mount_override(tmp_dir: Path, providers: list[str]) -> list[str]:
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py173def _setup_event_driven_integration(dot_env_file, tmp_dir):
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py222def _setup_xcom_object_storage_integration(dot_env_file, tmp_dir):
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py243def _setup_java_sdk_integration(dot_env_file, tmp_dir):
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py336def spin_up_airflow_environment(tmp_path_factory: pytest.TempPathFactory):
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py438def pytest_runtest_makereport(item, call):
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py112 def test_remote_logging_error_detail(self):
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py46def create_request_session_with_retries(status_forcelist: list[int]):
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py67 def test_java_tasks_execute_successfully(self, dag_id: str):
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py102 def test_transform_xcom_is_numeric_timestamp(self):
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py56def pull_value_from_bash_push(ti=None):
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py52 def _wait_for_kafka_consumer_group(self, compose_instance, timeout: int = 60, check_interval: int = 3):
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py73 def _wait_for_consumer_dag_runs(
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py138 def test_producer_triggers_consumer_and_kafka_offsets(self, compose_instance):
LOW…rflow_e2e_tests/basic_tests/test_airflowctl_imports.py24def test_airflowctl_is_importable():
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py58 def test_integration_run_dag_task_mapping(self):
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py82 def test_integration_run_dag_with_scheduler_failure(self):
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py112 def test_pod_failure_logging_with_container_terminated(self, mock_log):
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py173 def test_pod_failure_logging_exception_handling(self, mock_log):
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py209 def test_pod_failure_logging_non_failed_state(self, mock_log):
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py27def initialize_providers_manager():
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py44def create_connection_without_db(monkeypatch):
LOW…s-tests/tests/kubernetes_tests/test_other_executors.py52 def test_integration_run_dag_with_scheduler_failure(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py180 def test_do_xcom_push_defaults_false(self, kubeconfig_path, tmp_path):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py268 def test_skip_on_specified_exit_code(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py284 def test_already_checked_on_success(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py306 def test_already_checked_on_failure(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py624 def test_disable_privilege_escalation(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py666 def test_faulty_service_account(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py755 def test_pod_template_file_system(self, basic_pod_template):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py778 def test_pod_template_file_with_overrides_system(self, env_vars, test_label, basic_pod_template):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py805 def test_pod_template_file_with_full_pod_spec(self, test_label, basic_pod_template):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1068 def test_pod_priority_class_name(self, hook_mock, await_pod_completion_mock):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1158 def test_reattach_failing_pod_once(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1225 def test_changing_base_container_name_with_get_logs(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1250 def test_changing_base_container_name_no_logs(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1280 def test_changing_base_container_name_no_logs_long(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1311 def test_changing_base_container_name_failure(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1338 def test_base_container_name_init_precedence(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1388 def test_init_container_logs_filtered(self):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1472 def test_log_output_configurations(self, log_prefix_enabled, log_formatter, expected_log_message_check):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1507def test_hide_sensitive_field_in_templated_fields_on_error(caplog, monkeypatch):
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1554 def test_kubernetes_pod_operator_active_deadline_seconds(self, active_deadline_seconds, should_fail):
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py146 def _get_session_with_retries(self):
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py186 def _ensure_airflow_api_server_is_healthy(self):
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py245 def wait_until_task_in_executor(self, host, dag_run_id, dag_id, task_id, timeout=60):
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py291 def ensure_dag_expected_state(self, host, logical_date, dag_id, expected_final_state, timeout):
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py387 def get_generated_admin_password(self, namespace: str) -> str:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py414 def test_get_dag_queued_events(self):
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py425 def test_get_dag_queued_event(self):
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py685 def test_create_uses_schema_alias_in_request_body(self):
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py762 def test_update_uses_schema_alias_in_request_body(self):
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py130 def test_server_connection_refused(self):
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py201 def test_execute_list_sends_limit_to_server(self):
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py216 def test_execute_list_sends_limit_on_subsequent_pages(self):
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py234 def test_execute_list_rejects_non_positive_limit(self, limit):
19649 more matches not shown…
Over-Commented Block8015 hits · 7848 pts
SeverityFileLineSnippet
LOW.asf.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.asf.yaml81
LOWcodecov.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.hadolint.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOWpyproject.toml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.readthedocs.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.gitpod.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOWyamllint-config.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.markdownlint.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.cherry_picker.toml1# Licensed to the Apache Software Foundation (ASF) under one
LOWclients/python/pyproject.toml1# Licensed to the Apache Software Foundation (ASF) under one
LOWclients/python/test_python_client.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWclients/python/test_python_client.py41except ImportError:
LOWairflow-e2e-tests/.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/pyproject.toml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/docker/kafka.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/docker/localstack.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/docker/Dockerfile.java1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/docker/java.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/docker/opensearch.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/docker/elasticsearch.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/docker/kafka/update_run.sh1#!/bin/sh
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/tests/airflow_e2e_tests/constants.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/tests/airflow_e2e_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…sts/tests/airflow_e2e_tests/e2e_test_utils/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…sts/tests/airflow_e2e_tests/java_sdk_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py41# "extra": {
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…asticsearch_tests/test_remote_logging_elasticsearch.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…w_e2e_tests/remote_log_elasticsearch_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…ject_storage_tests/test_xcom_object_storage_backend.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…irflow_e2e_tests/xcom_object_storage_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…s/tests/airflow_e2e_tests/remote_log_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…flow_e2e_tests/remote_log_tests/test_remote_logging.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…tests/airflow_e2e_tests/event_driven_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…flow_e2e_tests/remote_log_opensearch_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…log_opensearch_tests/test_remote_logging_opensearch.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…sts/airflow_e2e_tests/basic_tests/test_example_dags.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…-tests/tests/airflow_e2e_tests/basic_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…low_e2e_tests/basic_tests/test_basic_dag_operations.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…rflow_e2e_tests/basic_tests/test_airflowctl_imports.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-e2e-tests/scripts/init-aws.sh1#!/bin/bash
LOWkubernetes-tests/.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOWkubernetes-tests/pyproject.toml1# Licensed to the Apache Software Foundation (ASF) under one
LOWkubernetes-tests/tests/kubernetes_tests/basic_pod.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…s-tests/tests/kubernetes_tests/test_other_executors.py1# Licensed to the Apache Software Foundation (ASF) under one
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWkubernetes-tests/tests/kubernetes_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py1# Licensed to the Apache Software Foundation (ASF) under one
LOWkubernetes-tests/tests/kubernetes_tests/pod.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOWairflow-ctl/.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under one
7955 more matches not shown…
Unused Imports5879 hits · 5628 pts
SeverityFileLineSnippet
LOWclients/python/test_python_client.py27
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py17
LOWairflow-e2e-tests/tests/airflow_e2e_tests/constants.py17
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py17
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py17
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py49
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py18
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py19
LOW…asticsearch_tests/test_remote_logging_elasticsearch.py17
LOW…ject_storage_tests/test_xcom_object_storage_backend.py17
LOW…flow_e2e_tests/remote_log_tests/test_remote_logging.py17
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py24
LOW…log_opensearch_tests/test_remote_logging_opensearch.py17
LOW…sts/airflow_e2e_tests/basic_tests/test_example_dags.py18
LOW…low_e2e_tests/basic_tests/test_basic_dag_operations.py17
LOW…rflow_e2e_tests/basic_tests/test_airflowctl_imports.py18
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py17
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py17
LOW…s-tests/tests/kubernetes_tests/test_other_executors.py17
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py17
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py17
LOWairflow-ctl/tests/conftest.py18
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py18
LOWairflow-ctl/tests/airflow_ctl/api/test_client.py18
LOW…w-ctl/tests/airflow_ctl/ctl/test_console_formatting.py17
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py18
LOW…ests/airflow_ctl/ctl/commands/test_variable_command.py17
LOW…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py19
LOW…s/airflow_ctl/ctl/commands/test_connections_command.py17
LOW…/tests/airflow_ctl/ctl/commands/test_config_command.py17
LOW…tests/airflow_ctl/ctl/commands/test_version_command.py17
LOW…ctl/tests/airflow_ctl/ctl/commands/test_dag_command.py17
LOW…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py17
LOWairflow-ctl/docs/conf.py21
LOW…iagrams/airflowctl_api_network_architecture_diagram.py17
LOWairflow-ctl/src/airflowctl/__init__.py18
LOWairflow-ctl/src/airflowctl/exceptions.py22
LOWairflow-ctl/src/airflowctl/__main__.py22
LOWairflow-ctl/src/airflowctl/utils/helpers.py18
LOWairflow-ctl/src/airflowctl/utils/module_loading.py18
LOWairflow-ctl/src/airflowctl/api/client.py18
LOWairflow-ctl/src/airflowctl/api/operations.py18
LOWairflow-ctl/src/airflowctl/api/datamodels/generated.py5
LOW…ow-ctl/src/airflowctl/api/datamodels/auth_generated.py5
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py21
LOWairflow-ctl/src/airflowctl/ctl/__init__.py20
LOWairflow-ctl/src/airflowctl/ctl/cli_parser.py25
LOWairflow-ctl/src/airflowctl/ctl/console_formatting.py17
LOWairflow-ctl/src/airflowctl/ctl/utils/yaml.py32
LOWairflow-ctl/src/airflowctl/ctl/utils/yaml.py37
LOWairflow-ctl/src/airflowctl/ctl/utils/yaml.py37
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py19
LOW…-ctl/src/airflowctl/ctl/commands/connection_command.py18
LOW…ow-ctl/src/airflowctl/ctl/commands/variable_command.py17
LOWairflow-ctl/src/airflowctl/ctl/commands/pool_command.py19
LOWairflow-ctl/src/airflowctl/ctl/commands/dag_command.py18
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py19
LOW…low-ctl/src/airflowctl/ctl/commands/version_command.py17
LOW…sts/tests/airflowctl_tests/test_airflowctl_commands.py17
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py17
5819 more matches not shown…
Cross-File Repetition726 hits · 3630 pts
SeverityFileLineSnippet
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so ple
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so ple
HIGHairflow-core/src/airflow/utils/state.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so ple
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wi
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wi
HIGHairflow-core/src/airflow/utils/state.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wi
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.
HIGHtask-sdk/src/airflow/sdk/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.
HIGHairflow-core/src/airflow/utils/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.
HIGHtask-sdk/src/airflow/sdk/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.
HIGHairflow-core/src/airflow/utils/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.
HIGHtask-sdk/tests/task_sdk/test_lineage.py0test that different contexts are tracked separately.
HIGHtask-sdk/tests/task_sdk/test_lineage.py0test that different contexts are tracked separately.
HIGH…n/compat/tests/unit/common/compat/lineage/test_hook.py0test that different contexts are tracked separately.
HIGH…n/compat/tests/unit/common/compat/lineage/test_hook.py0test that different contexts are tracked separately.
HIGHtask-sdk/tests/task_sdk/bases/test_operator.py0class for testing purpose: allows to create objects with custom attributes in one single statement.
HIGH…elery/tests/integration/celery/test_celery_executor.py0class for testing purpose: allows to create objects with custom attributes in one single statement.
HIGH…ore/tests/unit/serialization/test_dag_serialization.py0class for testing purpose: allows to create objects with custom attributes in one single statement.
HIGHairflow-core/tests/unit/models/test_renderedtifields.py0class for testing purpose: allows to create objects with custom attributes in one single statement.
HIGHtask-sdk/tests/task_sdk/bases/test_operator.py0verify if operator attributes are correctly templated.
HIGHtask-sdk/tests/task_sdk/bases/test_operator.py0verify if operator attributes are correctly templated.
HIGHtask-sdk/tests/task_sdk/bases/test_operator.py0verify if operator attributes are correctly templated.
HIGHtask-sdk/tests/task_sdk/bases/test_operator.py0verify if operator attributes are correctly templated.
HIGH…-sdk/tests/task_sdk/execution_time/test_task_runner.py0test that dag param is correctly resolved by operator
HIGH…-sdk/tests/task_sdk/execution_time/test_task_runner.py0test that dag param is correctly resolved by operator
HIGHtask-sdk/tests/task_sdk/definitions/test_dag.py0test that dag param is correctly resolved by operator
HIGHtask-sdk/tests/task_sdk/definitions/test_taskgroup.py0test that if a task group is empty, the dependencies between tasks are still maintained.
HIGHtask-sdk/tests/task_sdk/definitions/test_taskgroup.py0test that if a task group is empty, the dependencies between tasks are still maintained.
HIGHtask-sdk/tests/task_sdk/definitions/test_taskgroup.py0test that if a task group is empty, the dependencies between tasks are still maintained.
HIGHtask-sdk/tests/task_sdk/definitions/test_callback.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.
HIGHtask-sdk/tests/task_sdk/definitions/test_callback.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.
HIGH…re/tests/unit/serialization/test_serialized_objects.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.
HIGHairflow-core/tests/unit/models/test_dag.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.
HIGHairflow-core/tests/unit/models/test_deadline.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.
HIGHairflow-core/tests/unit/models/test_serialized_dag.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.
HIGHairflow-core/tests/unit/models/test_dagrun.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.
HIGHtask-sdk/src/airflow/sdk/plugins_manager.py0load plugins from plugins directory and entrypoints. plugins are only loaded if they have not been previously loaded.
HIGHairflow-core/src/airflow/plugins_manager.py0load plugins from plugins directory and entrypoints. plugins are only loaded if they have not been previously loaded.
HIGHairflow-core/src/airflow/plugins_manager.py0load plugins from plugins directory and entrypoints. plugins are only loaded if they have not been previously loaded.
HIGHtask-sdk/src/airflow/sdk/execution_time/comms.py0create result class from api response. api response is autogenerated from the api schema, so we need to convert it to re
HIGHtask-sdk/src/airflow/sdk/execution_time/comms.py0create result class from api response. api response is autogenerated from the api schema, so we need to convert it to re
HIGHtask-sdk/src/airflow/sdk/execution_time/comms.py0create result class from api response. api response is autogenerated from the api schema, so we need to convert it to re
HIGHtask-sdk/src/airflow/sdk/execution_time/comms.py0create result class from api response. api response is autogenerated from the api schema, so we need to convert it to re
HIGHtask-sdk/src/airflow/sdk/execution_time/comms.py0create result class from api response. api response is autogenerated from the api schema, so we need to convert it to re
HIGHairflow-core/src/airflow/jobs/triggerer_job_runner.py0create result class from api response. api response is autogenerated from the api schema, so we need to convert it to re
HIGHtask-sdk/src/airflow/sdk/definitions/deadline.py0a deadline that calculates the average runtime from past dag runs.
HIGH…core/src/airflow/serialization/definitions/deadline.py0a deadline that calculates the average runtime from past dag runs.
HIGHairflow-core/src/airflow/models/deadline.py0a deadline that calculates the average runtime from past dag runs.
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:
HIGH…/src/airflow/serialization/definitions/baseoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:
HIGH…/src/airflow/serialization/definitions/baseoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:
HIGH…/src/airflow/serialization/definitions/baseoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:
HIGHproviders/ftp/src/airflow/providers/ftp/assets/ftp.py0translate asset with valid aip-60 uri to openlineage with assistance from the hook.
HIGH…s/presto/src/airflow/providers/presto/assets/presto.py0translate asset with valid aip-60 uri to openlineage with assistance from the hook.
666 more matches not shown…
Hallucination Indicators234 hits · 2425 pts
SeverityFileLineSnippet
CRITICALairflow-ctl/src/airflowctl/ctl/cli_parser.py45from airflowctl.utils.helpers import partition
CRITICAL…tableau/src/airflow/providers/tableau/hooks/tableau.py27from airflow.utils.helpers import exactly_one
CRITICAL…unit/amazon/aws/triggers/test_opensearch_serverless.py29from airflow.utils.helpers import prune_dict
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py71 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py101 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py140 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(
CRITICAL…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py56from airflow.utils.helpers import convert_camel_to_snake
CRITICAL…unit/amazon/aws/executors/batch/test_batch_executor.py46from airflow.utils.helpers import convert_camel_to_snake
CRITICAL…ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py182 mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params)
CRITICAL…ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py201 mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params)
CRITICAL…oviders/amazon/tests/unit/amazon/aws/hooks/test_dms.py398 mock_conn.return_value.get_waiter.return_value.wait.assert_called_with(**expected_waiter_call_params)
CRITICAL…oviders/amazon/tests/unit/amazon/aws/hooks/test_eks.py100 from moto.core.exceptions import AWSError
CRITICAL…rs/amazon/tests/unit/amazon/aws/hooks/test_base_aws.py446 user_agent_dict = dict(tag.split("/") for tag in executor.ecs.meta.config.user_agent.split(" "))
CRITICAL…unit/amazon/aws/hooks/test_sagemaker_unified_studio.py113 self.hook._sagemaker_studio.execution_client.start_execution.assert_called_once()
CRITICAL…unit/amazon/aws/hooks/test_sagemaker_unified_studio.py124 self.hook._sagemaker_studio.execution_client.get_execution.assert_called()
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py357 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py412 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py455 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py512 hook.resource.Object.return_value.load.assert_called_with(
CRITICAL…/tests/unit/amazon/aws/auth_manager/avp/test_facade.py30from airflow.utils.helpers import prune_dict
CRITICALproviders/amazon/tests/system/amazon/aws/utils/k8s.py19from airflow.utils.helpers import exactly_one
CRITICAL…/providers/amazon/aws/sensors/opensearch_serverless.py29from airflow.utils.helpers import exactly_one
CRITICAL…c/airflow/providers/amazon/aws/operators/s3_vectors.py27from airflow.utils.helpers import prune_dict
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/rds.py38from airflow.utils.helpers import prune_dict
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/emr.py66from airflow.utils.helpers import exactly_one, prune_dict
CRITICAL…low/providers/amazon/aws/operators/redshift_cluster.py39from airflow.utils.helpers import prune_dict
CRITICAL…airflow/providers/amazon/aws/operators/glue_catalog.py27from airflow.utils.helpers import prune_dict
CRITICAL…/airflow/providers/amazon/aws/operators/eventbridge.py26from airflow.utils.helpers import prune_dict
CRITICAL…flow/providers/amazon/aws/operators/mwaa_serverless.py28from airflow.utils.helpers import prune_dict
CRITICAL…rc/airflow/providers/amazon/aws/operators/sagemaker.py50from airflow.utils.helpers import prune_dict
CRITICAL…roviders/amazon/aws/operators/opensearch_serverless.py29from airflow.utils.helpers import prune_dict
CRITICAL…rc/airflow/providers/amazon/aws/operators/s3_tables.py31from airflow.utils.helpers import prune_dict
CRITICAL…mazon/src/airflow/providers/amazon/aws/operators/s3.py35from airflow.utils.helpers import exactly_one
CRITICAL…/src/airflow/providers/amazon/aws/operators/bedrock.py43from airflow.utils.helpers import prune_dict
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/ecs.py43from airflow.utils.helpers import prune_dict
CRITICAL…providers/amazon/aws/triggers/opensearch_serverless.py23from airflow.utils.helpers import exactly_one
CRITICAL…azon/src/airflow/providers/amazon/aws/triggers/base.py27from airflow.utils.helpers import prune_dict
CRITICAL…zon/src/airflow/providers/amazon/aws/utils/__init__.py27from airflow.utils.helpers import prune_dict
CRITICAL…rflow/providers/amazon/aws/transfers/dynamodb_to_s3.py36from airflow.utils.helpers import prune_dict
CRITICAL…viders/amazon/aws/executors/ecs/ecs_executor_config.py46from airflow.utils.helpers import prune_dict
CRITICAL…low/providers/amazon/aws/executors/ecs/ecs_executor.py53from airflow.utils.helpers import merge_dicts
CRITICAL…providers/amazon/aws/executors/batch/batch_executor.py38from airflow.utils.helpers import merge_dicts
CRITICAL…rs/amazon/aws/executors/batch/batch_executor_config.py42from airflow.utils.helpers import prune_dict
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/links/emr.py26from airflow.utils.helpers import exactly_one
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/hooks/sqs.py23from airflow.utils.helpers import prune_dict
CRITICAL…/src/airflow/providers/amazon/aws/hooks/eventbridge.py22from airflow.utils.helpers import prune_dict
CRITICAL…/amazon/src/airflow/providers/amazon/aws/hooks/logs.py27from airflow.utils.helpers import prune_dict
CRITICAL…zon/src/airflow/providers/amazon/aws/hooks/base_aws.py60from airflow.utils.helpers import exactly_one
CRITICAL…rs/amazon/src/airflow/providers/amazon/aws/hooks/s3.py66from airflow.utils.helpers import chunks
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/hooks/sns.py25from airflow.utils.helpers import prune_dict
CRITICAL…irflow/providers/amazon/aws/auth_manager/avp/facade.py34from airflow.utils.helpers import prune_dict
CRITICAL…/src/airflow/providers/amazon/aws/notifications/ses.py26from airflow.utils.helpers import prune_dict
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py184 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py246 mock_client.secrets.kv.v2.read_secret_version.assert_not_called()
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py340 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py435 mock_client.secrets.kv.v1.read_secret.assert_called_once_with(**expected_args)
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py465 mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with(
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py720 mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with(
CRITICAL…ers/hashicorp/tests/unit/hashicorp/hooks/test_vault.py1137 mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with(
CRITICAL…ers/hashicorp/tests/unit/hashicorp/hooks/test_vault.py1176 mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with(
174 more matches not shown…
Decorative Section Separators375 hits · 1284 pts
SeverityFileLineSnippet
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py64# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py66# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py170# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py172# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py226# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py228# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py249# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py251# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py268# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py270# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py336# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py338# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py41# ---------------------------------------------------------------------------
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py43# ---------------------------------------------------------------------------
MEDIUM…low/providers/amazon/aws/executors/ecs/ecs_executor.py676 # ── Back-compat shims for renamed methods/attrs ────────────────────────
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1956 # -------------------------------------------------------------------------
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1958 # -------------------------------------------------------------------------
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py24# --------------------------------------------------------------------------------
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py26# --------------------------------------------------------------------------------
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py34# --------------------------------------------------------------------------------
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py37# --------------------------------------------------------------------------------
MEDIUM…azure/tests/unit/microsoft/azure/hooks/test_compute.py206 # ------------------------------------------------------------------
MEDIUM…azure/tests/unit/microsoft/azure/hooks/test_compute.py208 # ------------------------------------------------------------------
MEDIUM…src/airflow/providers/microsoft/azure/hooks/compute.py172 # ------------------------------------------------------------------
MEDIUM…src/airflow/providers/microsoft/azure/hooks/compute.py174 # ------------------------------------------------------------------
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py45# ----------------------------------------------------------------------
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py47# ----------------------------------------------------------------------
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py72# ----------------------------------------------------------------------
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py74# ----------------------------------------------------------------------
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py149 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py151 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py153 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py155 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py163 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py165 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py169 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py171 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py173 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py175 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py186 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py188 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py198 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py200 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py204 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py206 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py208 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py210 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py212 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py214 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py218 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py220 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py224 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py226 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py229 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py231 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py236 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py238 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py240 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py242 # ============================================================================
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py244 # ============================================================================
315 more matches not shown…
Excessive Try-Catch Wrapping1042 hits · 1104 pts
SeverityFileLineSnippet
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py408 except Exception:
LOW…ject_storage_tests/test_xcom_object_storage_backend.py65 except Exception as e:
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py163 except Exception:
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py198 except Exception as e:
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py85 except Exception as e:
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py119 except Exception as e:
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py183 except Exception as e:
LOW…-ctl/src/airflowctl/ctl/commands/connection_command.py46 except Exception as e:
LOW…-ctl/src/airflowctl/ctl/commands/connection_command.py73 except Exception as e:
LOWairflow-ctl/src/airflowctl/ctl/commands/pool_command.py82 except Exception as e:
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py823 except Exception as e:
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py251 except Exception as e:
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py258 except Exception as e:
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py288 except Exception as e:
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py340 except Exception:
LOW…k-sdk/tests/task_sdk/execution_time/test_supervisor.py1368 except Exception as e:
LOWtask-sdk/tests/task_sdk/execution_time/test_comms.py175 except Exception as e:
LOWtask-sdk/src/airflow/sdk/configuration.py159 except Exception as e:
LOWtask-sdk/src/airflow/sdk/log.py245 except Exception as exc:
LOWtask-sdk/src/airflow/sdk/log.py258 except Exception as exc:
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py98 except Exception as e:
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py552 except Exception:
LOWtask-sdk/src/airflow/sdk/plugins_manager.py94 except Exception as e:
LOWtask-sdk/src/airflow/sdk/lineage.py203 except Exception as e:
LOWtask-sdk/src/airflow/sdk/timezone.py38except Exception:
LOWtask-sdk/src/airflow/sdk/io/path.py161 except Exception:
LOWtask-sdk/src/airflow/sdk/bases/sensor.py220 except Exception as e:
LOWtask-sdk/src/airflow/sdk/bases/notifier.py139 except Exception as e:
LOWtask-sdk/src/airflow/sdk/bases/notifier.py153 except Exception as e:
LOWtask-sdk/src/airflow/sdk/execution_time/comms.py328 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py301 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py392 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py469 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py481 except Exception as e:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py890 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py924 except Exception as e:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1169 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1361 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1482 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1501 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1606 except Exception as e:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2278 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2430 except Exception as e:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2020 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2030 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2038 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2046 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2056 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2063 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1026 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1254 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1266 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1391 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1497 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1585 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1783 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1857 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2007 except Exception:
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2142 except Exception as e:
LOW…/src/airflow/sdk/execution_time/callback_supervisor.py142 except Exception as e:
982 more matches not shown…
Self-Referential Comments282 hits · 854 pts
SeverityFileLineSnippet
MEDIUMclients/python/test_python_client.py108 # Create a DAGRun object (no dag_id should be specified because it is read-only property of DAGRun)
MEDIUM…s/tests/airflow_e2e_tests/dags/example_event_driven.py107# Define a trigger that listens to an external message queue (Apache Kafka in this case)
MEDIUM…s/tests/airflow_e2e_tests/dags/example_event_driven.py118# Define an asset that watches for messages on the queue
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py119 # Create a mock KubernetesExecutor instance
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py136 # Create a test task key
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py179 # Create a mock KubernetesExecutor instance
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py183 # Create a test task key
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py215 # Create a mock KubernetesExecutor instance
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py220 # Create a test task key
MEDIUMairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py230 # Create a temporary file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py146 # Create a proper pool object with dictionary attributes instead of MagicMock
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py159 # Create a mock response with proper dictionary attributes
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py341 # Create a config file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py358 # Create a config file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py375 # Create a config file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py394 # Create a config file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py411 # Create a config file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py428 # Create a corrupted config file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py442 # Create a config file
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py293 # Create a config file
MEDIUMtask-sdk/tests/task_sdk/test_lineage.py722 # Create a large value
MEDIUMtask-sdk/tests/task_sdk/test_lineage.py778 # Create a non-serializable object
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py764 # Create a directory that exists
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py768 # Create a mock bundle instance
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py786 # Create a directory with read permissions
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py798 # Create a mock client to assert calls to the client
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py1259 # Create a fake placeholder in the open socket weakref
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py3398 # Create a simple TaskInstance datamodel to pass to the supervisor
MEDIUMtask-sdk/tests/task_sdk/definitions/test_dag.py328 # Create a linear chain: t1 -> t2 -> t3 -> t4 -> t5
MEDIUMtask-sdk/tests/task_sdk/definitions/test_dag.py363 # Create a diamond pattern:
MEDIUM…-sdk/tests/task_sdk/definitions/test_mappedoperator.py800 # Create a mapped task within the task group
MEDIUMtask-sdk/dev/datamodel_code_formatter.py109 # Create a replacement for 'Tasks' -> 'tuple[str, int]'
MEDIUMtask-sdk/src/airflow/sdk/execution_time/supervisor.py2036 # Create a socketpair preemptively, in case the task process runs VirtualEnv operator or run_as_user
MEDIUMtask-sdk/src/airflow/sdk/execution_time/supervisor.py2089 # Create a minimal supervisor instance for trigger execution
MEDIUM…sdk/src/airflow/sdk/execution_time/execute_workload.py66 # Create a mutually exclusive group to ensure that only one of the flags is set
MEDIUMtask-sdk/src/airflow/sdk/api/client.py303 # Create a deferred state payload from msg
MEDIUMtask-sdk/src/airflow/sdk/api/client.py310 # Create a reschedule state payload from msg
MEDIUMproviders-summary-docs/conf.py26# This file is execfile()d with the current directory set to its
MEDIUM…ders/presto/tests/unit/presto/hooks/test_presto_sql.py149 # Create a real Airflow connection
MEDIUM…it/amazon/aws/sensors/test_sagemaker_unified_studio.py91 # Create the sensor
MEDIUM…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1034 # Create a temporary credentials file
MEDIUM…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1093 # Create a temporary credentials file
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py141 # Create the operator
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py189 # Create the operator with wait_for_completion set to True
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py239 # Create the operator with wait_for_completion set to False
MEDIUM…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py173 # Create a test file remotely
MEDIUM…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py183 # Create a new Collection and verify it is empty.
MEDIUM…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py275 # Create a new Collection and add a two tasks.
MEDIUM…mazon/aws/executors/aws_lambda/test_lambda_executor.py1184 # Create a team-specific executor.
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py106 # Create the local log file structure
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py153 # Create a logger factory and pass in the file path we want it to use
MEDIUM…viders/amazon/tests/unit/amazon/aws/bundles/test_s3.py195 # Create a pytest Call object to compare against the call_args_list of the _log.debug mock
MEDIUM…ders/amazon/tests/system/amazon/aws/example_bedrock.py65# Creating a custom model takes nearly two hours. If SKIP_LONG_TASKS
MEDIUM…tests/system/amazon/aws/example_eks_with_nodegroups.py94 # Create an Amazon EKS Cluster control plane without attaching compute service.
MEDIUM…ers/amazon/tests/system/amazon/aws/example_datasync.py184 # Create a task (the task does not exist)
MEDIUM…/system/amazon/aws/example_eks_with_fargate_profile.py78 # Create an Amazon EKS Cluster control plane without attaching a compute service.
MEDIUM…m/amazon/aws/example_eks_with_nodegroup_in_one_step.py92 # Create an Amazon EKS cluster control plane and an EKS nodegroup compute platform in one step.
MEDIUMproviders/amazon/tests/system/amazon/aws/example_ec2.py62 # Creating the key takes a very short but measurable time, preventing race condition:
MEDIUM…azon/tests/system/amazon/aws/example_dms_serverless.py118 # Create the Table.
MEDIUM…azon/tests/system/amazon/aws/example_step_functions.py57 # Create a Step Functions State Machine and return the ARN for use by
222 more matches not shown…
Deep Nesting858 hits · 756 pts
SeverityFileLineSnippet
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py336
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py245
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py216
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py566
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py747
LOWairflow-ctl/src/airflowctl/api/client.py198
LOWairflow-ctl/src/airflowctl/api/client.py249
LOWairflow-ctl/src/airflowctl/api/operations.py157
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py839
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py411
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py605
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py684
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py688
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py124
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py720
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py104
LOWtask-sdk/tests/conftest.py178
LOW…k-sdk/tests/task_sdk/test_providers_manager_runtime.py172
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py5255
LOW…k-sdk/tests/task_sdk/execution_time/test_supervisor.py3456
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py218
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py275
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py619
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py1030
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py1043
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py1047
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py438
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py493
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py607
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py460
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py512
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py647
LOWtask-sdk/src/airflow/sdk/configuration.py170
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py235
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py289
LOW…k-sdk/src/airflow/sdk/coordinators/java/coordinator.py146
LOWtask-sdk/src/airflow/sdk/io/fs.py52
LOWtask-sdk/src/airflow/sdk/bases/sensor.py183
LOWtask-sdk/src/airflow/sdk/bases/decorator.py279
LOWtask-sdk/src/airflow/sdk/bases/operator.py1998
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py980
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1101
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1437
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1652
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1198
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1211
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1326
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1986
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2083
LOW…/src/airflow/sdk/execution_time/callback_supervisor.py275
LOWtask-sdk/src/airflow/sdk/execution_time/context.py261
LOWtask-sdk/src/airflow/sdk/execution_time/context.py1250
LOWtask-sdk/src/airflow/sdk/execution_time/context.py754
LOWtask-sdk/src/airflow/sdk/execution_time/context.py1094
LOW…-sdk/src/airflow/sdk/execution_time/schema/__init__.py74
LOWtask-sdk/src/airflow/sdk/definitions/mappedoperator.py117
LOWtask-sdk/src/airflow/sdk/definitions/xcom_arg.py100
LOWtask-sdk/src/airflow/sdk/definitions/dag.py1465
LOWtask-sdk/src/airflow/sdk/definitions/dag.py762
LOWtask-sdk/src/airflow/sdk/definitions/dag.py895
798 more matches not shown…
Cross-Language Confusion127 hits · 726 pts
SeverityFileLineSnippet
HIGH…tests/kubernetes_tests/test_kubernetes_pod_operator.py546 'echo "retrieved from mount" > /tmp/test_volume/test.txt && cat /tmp/test_volume/test.txt'
HIGHtask-sdk/tests/task_sdk/api/test_client.py772 # Return None (null) when no previous TI found
HIGHtask-sdk/tests/task_sdk/api/test_client.py1540 # Return None (null) when no previous Dag run found
HIGHtask-sdk/tests/task_sdk/serde/test_serializers.py264 assert i.equals(d)
HIGHtask-sdk/src/airflow/sdk/bases/operator.py1526 DagContext.push(None)
HIGHtask-sdk/src/airflow/sdk/definitions/dag.py741 DagContext.push(self)
HIGHtask-sdk/src/airflow/sdk/definitions/taskgroup.py393 TaskGroupContext.push(self)
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py139 assert read_df.equals(test_df)
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py238 assert df.equals(
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py248 assert df.equals(
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py290 assert df.equals(
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py332 assert df.equals(
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py342 assert df.equals(
HIGH…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py431 '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}',
HIGH…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py441 '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}',
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py59 if command -v yum &> /dev/null; then
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py61 elif command -v dnf &> /dev/null; then
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py69 if ! command -v amazon-ssm-agent &> /dev/null; then
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py40 backend_kwargs = {"connections_prefix": "/airflow/connections", "profile_name": null}
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py48 If set to None (null), requests for connections will not be sent to AWS SSM Parameter Store.
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py54 If set to None (null), requests for variables will not be sent to AWS SSM Parameter Store.
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py60 If set to None (null), requests for configurations will not be sent to AWS SSM Parameter Store.
HIGH…mazon/src/airflow/providers/amazon/aws/hooks/athena.py258 self.log.error("Invalid Query state (null). Query execution id: %s", query_execution_id)
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py95 ssh_client.exec_command.assert_called_once_with("uname || ver")
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py53 ssh_client.exec_command.assert_called_once_with("uname || ver")
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py67 ssh_client.exec_command.assert_called_once_with("uname || ver")
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py81 ssh_client.exec_command.assert_called_once_with("uname || ver")
HIGH…data/src/airflow/providers/teradata/utils/bteq_util.py32 stdin, stdout, stderr = ssh_client.exec_command("uname || ver")
HIGH…adata/src/airflow/providers/teradata/utils/tpt_util.py132 f"dd if=/dev/zero of={file_path} bs=4096 count=$(($(stat -c '%s' {file_path})/4096+1)) 2>/dev/nu
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py51 (default: 'connections'). If set to None (null), requests for connections will not be sent to Vault.
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py53 (default: 'variables'). If set to None (null), requests for variables will not be sent to Vault.
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py55 (default: 'config'). If set to None (null), requests for configurations will not be sent to Vault.
HIGH…ts/unit/google/cloud/transfers/test_postgres_to_gcs.py44 b'{"some_json": {"firtname": "John", "lastname": "Smith", "nested_dict": {"a": null, "b": "something"}}, "some_num":
HIGH…ts/unit/google/cloud/transfers/test_postgres_to_gcs.py73 "nested_dict": {"a": null, "b": "something"}}',
HIGH…tests/unit/google/cloud/transfers/test_mssql_to_gcs.py298 assert schema.field("some_binary").type.equals(pyarrow.bool_())
HIGH…tests/unit/google/cloud/transfers/test_mssql_to_gcs.py299 assert schema.field("some_bit").type.equals(pyarrow.bool_())
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py398 assert df.equals(OUTPUT_DF)
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py420 assert df.equals(OUTPUT_DF)
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py442 assert df.equals(OUTPUT_DF)
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py472 assert df.equals(output_df)
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py501 assert df.equals(OUTPUT_DF_WITH_EXCLUDE_COLUMNS)
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py529 assert concat_df.equals(OUTPUT_DF)
HIGH…system/google/cloud/cloud_build/example_cloud_build.py69 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}],
HIGH…system/google/cloud/cloud_build/example_cloud_build.py76 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}],
HIGH…system/google/cloud/cloud_build/example_cloud_build.py82 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 300"]}],
HIGH…oogle/tests/system/google/cloud/ray/example_ray_job.py93 entrypoint="echo hi && sleep 105 && echo hi2",
HIGH…s/google/src/airflow/providers/google/ads/hooks/ads.py57 "json_key_file_path": null,
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py64 If set to None (null), requests for connections will not be sent to GCP Secrets Manager
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py66 If set to None (null), requests for variables will not be sent to GCP Secrets Manager
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py69 If set to None (null), requests for configurations will not be sent to GCP Secrets Manager
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py71 If set to None (null), requests for connections will not be sent to Azure Key Vault
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py73 If set to None (null), requests for variables will not be sent to Azure Key Vault
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py75 If set to None (null), requests for configurations will not be sent to Azure Key Vault
HIGH…s/standard/tests/unit/standard/decorators/test_bash.py152 assert bash_task.operator.bash_command == "echo hello world && echo 2"
HIGH…s/standard/tests/unit/standard/decorators/test_bash.py155 self.validate_bash_command_rtif(ti, "echo hello world && echo 2")
HIGH…/sql/src/airflow/providers/common/sql/operators/sql.py1606 self.push(meta_data)
HIGH…ders/ssh/src/airflow/providers/ssh/utils/remote_job.py328 return f"stat -c%s '{file_path}' 2>/dev/null || stat -f%z '{file_path}' 2>/dev/null || echo 0"
HIGH…ders/ssh/src/airflow/providers/ssh/utils/remote_job.py385 return f"test -f '{pid_file}' && kill $(cat '{pid_file}') 2>/dev/null || true"
HIGH…ders/ssh/src/airflow/providers/ssh/utils/remote_job.py440 return "uname -s 2>/dev/null || echo UNKNOWN"
HIGH…neage/tests/unit/openlineage/extractors/test_python.py46bash_task = BashOperator(task_id="bash-task", bash_command="ls -halt && exit 0", dag=dag)
67 more matches not shown…
Redundant / Tautological Comments225 hits · 333 pts
SeverityFileLineSnippet
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py129 # Check if directory exists
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py201 # Display results
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py1916 # Assign task to Dag
LOWtask-sdk/dev/datamodel_code_formatter.py102 # Check if the target is 'tasks'
LOWtask-sdk/src/airflow/sdk/configuration.py274 # Check if the secrets_backend_list contains only 2 default backends.
LOWtask-sdk/src/airflow/sdk/configuration.py276 # Check if we are loading the backends for worker too by checking if the default_backends is equal
LOWtask-sdk/src/airflow/sdk/bases/decorator.py223 # Check if args conflict with names in kwargs.
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1098 # Check if the subprocess has exited
LOWtask-sdk/src/airflow/sdk/definitions/taskgroup.py377 # Check if the current TaskGroup is empty
LOW…/airflow/sdk/definitions/_internal/abstractoperator.py240 # Check if the operator has an explicit native rendering preference
LOWtask-sdk/src/airflow/sdk/serde/typing.py32 # Check if it is not a dataclass to prevent detecting pydantic dataclasses as pydantic models
LOW…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1141 # Set status to None so define_container_state returns UNDEFINED (not terminal)
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py89 # Check if object was created in s3
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py162 # Check if object was created in s3
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py220 # Check if object was created in s3
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py278 # Check if object was created in s3
LOW…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py114 # Check if object was created in s3
LOW…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py205 # Check if object was created in s3
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py171 # Check if a file exists
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py180 # Check if both files exist
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py189 # Check if a file exists
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py199 # Check if both files exist
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py209 # Check if a file exists and match a certain pattern defined in check_fn
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py220 # Check if a file exists and match a certain regular expression pattern
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py231 # Check if a file exists and match a certain pattern defined in check_fn
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py241 # Check if a file exists and match a certain regular expression pattern
LOWproviders/amazon/tests/system/amazon/aws/example_emr.py92 # Set KeepJobFlowAliveWhenNoSteps to False to avoid the cluster from being torn down prematurely.
LOW…amazon/src/airflow/providers/amazon/aws/sensors/ssm.py118 # Check if we should tolerate this failure
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py323 # Set wait_for_completion to False so that it waits for the status in the deferred task.
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py783 # Set wait_for_completion to False so that it waits for the status in the deferred task.
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py1181 # Set wait_for_completion to False so that it waits for the status in the deferred task.
LOW…irflow/providers/amazon/aws/operators/redshift_data.py133 # Set wait_for_completion to False so that it waits for the status in the deferred task.
LOW…rflow/providers/amazon/aws/transfers/glacier_to_gcs.py99 # Read the file content in chunks using StreamingBody
LOW…low/providers/amazon/aws/executors/ecs/ecs_executor.py120 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the global
LOW…providers/amazon/aws/executors/batch/batch_executor.py110 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the global
LOW…ers/amazon/aws/executors/aws_lambda/lambda_executor.py88 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the global
LOW…zon/src/airflow/providers/amazon/aws/hooks/base_aws.py581 # Check if we can find an executor
LOW…ers/teradata/tests/unit/teradata/operators/test_tpt.py292 # Set hook to None
LOW…ers/teradata/tests/unit/teradata/operators/test_tpt.py708 # Set hooks to None
LOW…rs/teradata/tests/unit/teradata/utils/test_tpt_util.py540 # Check if permissions were set correctly
LOW…adata/src/airflow/providers/teradata/operators/bteq.py43 # Check if the parameter contains Jinja templating syntax
LOW…data/src/airflow/providers/teradata/utils/bteq_util.py50 # Check if zsh exists first
LOW…adata/src/airflow/providers/teradata/utils/tpt_util.py77 # Check if shred is available
LOW…adata/src/airflow/providers/teradata/utils/tpt_util.py110 # Check if shred is available on remote system (UNIX/Linux)
LOW…dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py62 # Check if ``account_id`` was not included in the function signature or, if it is, the value is not
LOW…dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py843 # Check if the job-run duration has exceeded the ``timeout`` configured.
LOW…irflow/providers/edge3/plugins/edge_executor_plugin.py56# Check if EdgeExecutor is actually loaded
LOW…src/airflow/providers/edge3/executors/edge_executor.py61 # Check if self has the ExecutorConf set on the self.conf attribute with all required methods.
LOW…src/airflow/providers/edge3/executors/edge_executor.py111 # Check if job already exists with same dag_id, task_id, run_id, map_index, try_number
LOW…e3/src/airflow/providers/edge3/worker_api/routes/ui.py290 # Check if worker exists first
LOW…/providers/google/common/utils/id_token_credentials.py151 # Check if application default credentials exist.
LOW…viders/google/cloud/sensors/vertex_ai/feature_store.py85 # Check if the sync has completed by verifying end_time exists
LOW…c/airflow/providers/google/cloud/operators/dataproc.py940 # Check if cluster is not in ERROR state.
LOW…airflow/providers/google/cloud/transfers/gcs_to_gcs.py295 # Check if prefix contains wildcard
LOW…e/src/airflow/providers/google/cloud/hooks/bigquery.py303 # Check if tableReference is present and is valid
LOW…e/src/airflow/providers/google/cloud/hooks/bigquery.py310 # Check if value is already present if no use the provided one
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py403 # Verify if the output table id from the parse result matches the BQ job output table
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py412 # Verify if all columns from parse results are present in the output dataset schema
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py421 # Verify if all datasets from parse results are present in bq job input datasets
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py425 # Verify if all columns from parse results are present in their respective bq job input datasets
165 more matches not shown…
Overly Generic Function Names200 hits · 150 pts
SeverityFileLineSnippet
LOWairflow-ctl/tests/conftest.py65 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py377 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py386 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py395 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py404 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py415 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py426 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py492 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py501 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py510 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py519 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py528 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py659 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py668 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py677 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py692 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py745 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py754 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py769 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1020 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1029 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1038 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1047 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1056 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1065 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1074 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1083 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1094 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1103 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1112 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1381 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1390 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1399 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1408 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1417 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1484 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1493 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1502 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1511 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1520 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1529 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py340 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py349 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py363 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py468 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py481 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py556 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py572 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py596 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py708 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py732 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py797 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py816 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1123 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1134 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1182 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1191 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1244 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1266 def handle_request(request: httpx.Request) -> httpx.Response:
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1297 def handle_request(request: httpx.Request) -> httpx.Response:
140 more matches not shown…
Verbosity Indicators58 hits · 84 pts
SeverityFileLineSnippet
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py637 # Step 1: Simulate CLI args being parsed (logical_date=None)
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py651 # Step 2: Apply the defaulting logic (from cli_config.py lines 622-630)
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py662 # Step 3: Create the Pydantic model (what happens in the actual code)
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py665 # Step 4: Verify logical_date was set to now
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py589 # Step 1: create the dag run span and capture its carrier.
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py596 # Step 2: derive the parent task span carrier (child of dag run), as the scheduler does.
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py606 # Step 3: build StartupDetails with ti.context_carrier = ti_carrier.
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py627 # Step 4: emit the worker span (task runner side).
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py633 # Step 5: emit the parent task span (API server side, as happens on task completion).
LOWtask-sdk/src/airflow/sdk/bases/decorator.py133 # We need to check if we are in the context of TaskGroup as the task_id may
LOW…google/cloud/compute/example_compute_recreate_drift.py91 # Step 1: Create with machine type A.
LOW…google/cloud/compute/example_compute_recreate_drift.py102 # Step 2: Re-run with different machine type and recreate recreate_if_machine_type_different=True.
LOW…google/cloud/compute/example_compute_recreate_drift.py114 # Step 3: Validate new machine type.
LOW…google/cloud/compute/example_compute_recreate_drift.py120 # Step 4: Cleanup.
LOW…iders/cncf/kubernetes/executors/kubernetes_executor.py587 # therefore, we need to check if the TIs are already adopted by the first attempt and remove them.
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py156 # Step 1: Decompose the high-level question into sub-questions,
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py185 # Step 2: Generate SQL for each sub-question in parallel.
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py199 # Step 3: Wrap each SQL string into a single-element list.
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py210 # Step 4: Execute each SQL against the survey CSV via DataFusion.
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py221 # Step 5: Collect all four JSON results and label them by dimension.
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py240 # Step 6: Synthesize the four labeled result sets into a narrative.
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py259 # Step 7: Human reviews the synthesized narrative before the DAG ends.
LOW…common/ai/example_dags/example_aip_progress_tracker.py191 # Step 1: Fetch the list of active AIPs to investigate.
LOW…common/ai/example_dags/example_aip_progress_tracker.py214 # Step 2: Gather evidence for each AIP from multiple sources.
LOW…common/ai/example_dags/example_aip_progress_tracker.py248 # Step 3: Format the gathered evidence into an LLM analysis prompt.
LOW…common/ai/example_dags/example_aip_progress_tracker.py266 # Step 4: Analyze each AIP with a structured LLM call.
LOW…common/ai/example_dags/example_aip_progress_tracker.py280 # Step 5: Collect all per-AIP analyses into a single context string
LOW…common/ai/example_dags/example_aip_progress_tracker.py304 # Step 6: Synthesize a cross-AIP progress report.
LOW…common/ai/example_dags/example_aip_progress_tracker.py328 # Step 7: A maintainer reviews the synthesized report before it is
LOW…/common/ai/example_dags/example_llm_survey_analysis.py312 # Step 4: SQL generation -- LLM translates the fixed question.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py324 # Step 5: SQL execution via Apache DataFusion.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py334 # Step 6: Extract data rows from the JSON result.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py346 # Step 7: Send result via email if SMTP is configured, otherwise log.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py167 # Step 1: Prompt confirmation -- review or edit the question.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py183 # Step 2: SQL generation -- LLM translates the confirmed question.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py194 # Step 3: SQL execution via Apache DataFusion.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py204 # Step 4: Extract data rows from the JSON result.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py217 # Step 5: Result confirmation -- approve or reject the query result.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py266 # Step 1: Download the survey CSV from the Airflow website.
LOW…/common/ai/example_dags/example_llm_survey_analysis.py278 # Step 2: Write the downloaded CSV to disk and generate a reference
LOW…/common/ai/example_dags/example_llm_survey_analysis.py297 # Step 3: Validate the downloaded CSV schema against the reference.
LOW…ets_masker/tests/secrets_masker/test_secrets_masker.py1528 # Step 1: Redact the original data
LOW…ets_masker/tests/secrets_masker/test_secrets_masker.py1536 # Step 2: User modifies some fields
LOW…ets_masker/tests/secrets_masker/test_secrets_masker.py1543 # Step 3: Merge to restore unchanged sensitive values
LOWairflow-core/tests/unit/jobs/test_scheduler_job.py2433 # Step 1: ti1 is deferred, ti2 scheduled -> ti2 blocked
LOWairflow-core/tests/unit/jobs/test_scheduler_job.py2443 # Step 2: ti1 completes -> ti2 should be unblocked
LOWairflow-core/src/airflow/utils/db.py1052 # Before checking if the _current_ value exists, we need to check if the old config value we upgraded in
LOW…ow-core/src/airflow/cli/commands/api_server_command.py135 # So we need to check if the log_config is set to "-" or not; if it is set to "-", we regard it as not set.
LOWscripts/ci/prek/check_security_doc_constants.py390 # Step 1: Auto-update the sensitive var tables
LOWscripts/ci/prek/check_security_doc_constants.py400 # Step 2: Validate references (re-read after potential update)
LOW…reeze/src/airflow_breeze/commands/registry_commands.py455 # Step 1: extract_versions.py (host, reads git tags) -> metadata.json
LOW…reeze/src/airflow_breeze/commands/registry_commands.py463 # Step 2: extract_parameters.py + extract_connections.py
LOW…sdk-integration-tests/tests/task_sdk_tests/conftest.py485 # Step 1: Get DAG status
LOW…sdk-integration-tests/tests/task_sdk_tests/conftest.py493 # Step 2: Unpause DAG if needed
LOW…sdk-integration-tests/tests/task_sdk_tests/conftest.py502 # Step 3: Trigger DAG run
LOW…sdk-integration-tests/tests/task_sdk_tests/conftest.py516 # Step 4: Wait for condition
LOW…sdk-integration-tests/tests/task_sdk_tests/conftest.py549 # Step 5: Get task instance ID
LOW…sdk-integration-tests/tests/task_sdk_tests/conftest.py618 # Step 6: Generate JWT token and create SDK client
AI Slop Vocabulary36 hits · 71 pts
SeverityFileLineSnippet
MEDIUMtask-sdk/tests/task_sdk/bases/test_operator.py83# Essentially similar to airflow.models.baseoperator.BaseOperator
LOWtask-sdk/src/airflow/sdk/execution_time/comms.py203 # `__class_getitem__`, but that's a lot of code the one subclass we've got currently. So we'll just use a
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2158# and it doesn't contain a new line character, `.readline()` will just return the chunk as is.
LOW…rs/amazon/tests/unit/amazon/aws/hooks/test_datasync.py43# mock_get_conn. We then override it to just return the locally created self.client instead of
LOW…/amazon/src/airflow/providers/amazon/aws/sensors/s3.py182 # Otherwise, just pass the files
LOW…irflow/providers/amazon/aws/operators/redshift_data.py210 # case, pull each of the sub-statement ID's, and grab the results. Otherwise, just use statement_id
MEDIUM…viders/edge3/src/airflow/providers/edge3/cli/worker.py538 # Technically safer and more robust, but with more overhead
MEDIUM…irflow/providers/google/cloud/utils/field_validator.py350 # Certainly down from here the field is present (value is not None)
LOW…w/providers/google/cloud/utils/credentials_provider.py498 # if it's already a dict, just return it
MEDIUM…rc/airflow/providers/google/cloud/hooks/compute_ssh.py42# TODO:(potiuk) We should add test harness detecting such cases shortly
LOW…e/src/airflow/providers/snowflake/utils/openlineage.py107 # else - its new hostname, just return it
LOW…lineage/tests/unit/openlineage/extractors/test_base.py454 # just return empty OperatorLineage
LOW…lineage/src/airflow/providers/openlineage/utils/sql.py203 # Don't iterate over tables hierarchy, just pass it to query single information schema table
LOW…e/src/airflow/providers/salesforce/hooks/salesforce.py252 # just return the original column untouched
MEDIUMchart/values.yaml31# For now this is an opt-in switch for backwards compatibility to leverage the standard naming convention
MEDIUMchart/values.yaml356# Specify executors in a prioritized list to leverage multiple execution environments as needed:
MEDIUMchart/files/statsd-mappings.yml21# instead utilize `statsd.extraMappings` or `statsd.overrideMappings` in your environment,
LOW…nfiguration/src/airflow_shared/configuration/parser.py1423 # have these types is with `fallback=` was specified. So just return it.
LOW…ared/logging/src/airflow_shared/logging/_noncaching.py36 # we should simply return the wrapper retrieved by FileHandler's open method
LOWairflow-core/tests/unit/cli/test_hot_reload.py63 # Should just call the callback directly
LOW…/src/airflow/api_fastapi/execution_api/routes/xcoms.py320# TODO: once we have JWT tokens, then remove dag_id/run_id/task_id from the URL and just use the info in
MEDIUM…c/airflow/config_templates/default_webserver_config.py111# in order to fully utilize the theme. (or use that property in conjunction with theme)
MEDIUM…c/airflow/config_templates/default_webserver_config.py111# in order to fully utilize the theme. (or use that property in conjunction with theme)
LOWairflow-core/src/airflow/timetables/trigger.py281 # values, so we can just use the first to represent them.
MEDIUMairflow-core/src/airflow/triggers/base.py450 """Yield this event in order to end the task successfully."""
MEDIUMairflow-core/src/airflow/triggers/base.py456 """Yield this event in order to end the task with failure."""
MEDIUMairflow-core/src/airflow/triggers/base.py462 """Yield this event in order to end the task with status 'skipped'."""
LOWairflow-core/src/airflow/serialization/encoders.py391 # values, so we can just use the first to represent them.
LOWairflow-core/src/airflow/utils/db.py1489 # Older version before we added that function, it only has a single migration so we can just create the tables
LOWairflow-core/src/airflow/utils/dot_renderer.py241 # (we can just use the maybe-None label variable directly)
LOWairflow-core/src/airflow/utils/sqlalchemy.py219 # below is the only line we change, and we just add default=None for getattr
LOW…core/src/airflow/utils/log/non_caching_file_handler.py31 # we should simply return the wrapper retrieved by FileHandler's open method
LOWairflow-core/src/airflow/cli/commands/db_command.py66 # Exact match found, we can just return it
LOW…flow-core/src/airflow/dag_processing/importers/base.py238 # If it's a file, just return it if we can handle it
LOWdev/breeze/src/airflow_breeze/params/shell_params.py518 # Socket is something different (TCP?) just pass it through as DOCKER_HOST variable
MEDIUM…airflow_breeze/commands/release_management_commands.py2102 """Cleans up the old airflow providers artifacts in order to maintain
Slop Phrases28 hits · 68 pts
SeverityFileLineSnippet
LOWclients/python/test_python_client.py53# auth manager for instance AwsAuthManagerUser or SimpleAuthManager make sure to generate the token with
LOWairflow-ctl/src/airflowctl/api/client.py113 # If you are updating here don't forget to update the airflow-ctl-tests
LOWairflow-ctl/src/airflowctl/api/client.py113 # If you are updating here don't forget to update the airflow-ctl-tests
LOW…mazon/tests/system/amazon/aws/example_mwaa_airflow2.py58 # If creating the environment using the AWS console, make sure to have a VPC with
LOW…oviders/amazon/tests/system/amazon/aws/example_mwaa.py59 # If creating the environment using the AWS console, make sure to have a VPC with
MEDIUM…adata/src/airflow/providers/teradata/hooks/teradata.py84 # Optionally, you can replace the original value in the query_band_text
MEDIUM…stem/google/cloud/dataplex/example_dataplex_catalog.py80 "description": "A simple AspectType for demonstration purposes.",
MEDIUM…ers/pgvector/tests/system/pgvector/example_pgvector.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, task
MEDIUM…ector/tests/system/pgvector/example_pgvector_openai.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, task, teardown
MEDIUM…ineage/tests/unit/openlineage/plugins/test_listener.py351 # Now you can use listener and task_instance in your tests to simulate their interaction.
MEDIUM…ineage/tests/unit/openlineage/plugins/test_listener.py1208 # Now you can use listener and task_instance in your tests to simulate their interaction.
MEDIUM…airbyte/src/airflow/providers/airbyte/hooks/airbyte.py61 # Intentionally left the password out, you can modify the log to print it out if you are doing testing.
MEDIUM…irflow/providers/apache/tinkerpop/operators/gremlin.py46 # If you prefer, you can add an alias run_query = run in your hook.
MEDIUMproviders/openai/tests/system/openai/example_openai.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, task
MEDIUMchart/values.yaml509 # or, you can use a different database like:
MEDIUMchart/values.yaml609 # This is an example config showing how you can use templating and how "example" config
LOW…art/tests/helm_tests/airflow_aux/test_chart_quality.py36 # we don't forget to update the schema if we add a new property
LOW…art/tests/helm_tests/airflow_aux/test_chart_quality.py36 # we don't forget to update the schema if we add a new property
MEDIUM…low-core/docs/howto/docker-compose/docker-compose.yaml45# Feel free to modify this file to suit your needs.
MEDIUM…low-core/docs/howto/docker-compose/docker-compose.yaml49 # In order to add custom dependencies or upgrade provider distributions you can use your extended image.
MEDIUM…c/airflow/config_templates/default_webserver_config.py108# that you can use for Apache Airflow.
LOW…c/airflow/config_templates/default_webserver_config.py110# Please make sure to remove "navbar_color" configuration from airflow.cfg
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py52 # Therefore you can add the "section" attribute.
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py54 # Note if you can add any Markdown formatting to the description, you need to use the description_md
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py69 # If you want to have a selection list box then you can use the enum feature of JSON schema
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py159 # then you can use the examples feature of JSON schema
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py279 # then you can use the JSON schema option of passing constant values. These parameters
LOWscripts/ci/prek/check_integrations_list.py201 "[yellow]Regenerating documentation table. Don't forget to review and commit possible changes.[/]"
Docstring Block Structure12 hits · 60 pts
SeverityFileLineSnippet
HIGH…radata/src/airflow/providers/teradata/operators/tpt.py176 Normalize error_list parameter to a list of integers. Args: error_list: An integer, list o
HIGH…radata/src/airflow/providers/teradata/operators/tpt.py577 Handle execution using a local job variable file. Args: file_path: Path to the local job v
HIGH…s/teradata/src/airflow/providers/teradata/hooks/tpt.py86 Execute a DDL statement using TPT. Args: tpt_script: TPT script content as string or list
HIGH…s/teradata/src/airflow/providers/teradata/hooks/tpt.py247 Execute a tdload operation using the tdload command-line utility. Args: remote_working_dir
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py63 Merge multiple column lineage facets into a single consolidated facet. Specifically, it aggregates input field
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py163 Extract and process the dataset name from a given path. Args: path: The path to process e.g. of a gcs
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py276 Get column lineage facet for identity transformations. This function generates a simple column lineage facet,
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py418 Replace the properties of a specific job type in a Dataproc job definition. Args: job: The original Da
HIGH…ndard/src/airflow/providers/standard/operators/hitl.py275 Generate a URL link to the "required actions" page for a specific task instance. This URL includes que
HIGH…e/tests/system/openlineage/expected_events/__init__.py30 Retrieve the file path to the OpenLineage expected events JSON file for a given DAG ID, taking into account the
HIGH…c/airflow/api_fastapi/core_api/services/ui/calendar.py288 Get database-specific time truncation expression for SQLAlchemy. We want to return always timestamp fo
HIGH…sdk-integration-tests/tests/task_sdk_tests/conftest.py436 Utility to set up a DAG run and create an SDK client. This function handles the common pattern of: 1. Gett
Fake / Example Data33 hits · 36 pts
SeverityFileLineSnippet
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py3266 secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py3266 secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py237 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py252 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py268 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"
LOW…/teradata/tests/system/teradata/example_remote_bteq.py87 INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT');
LOWproviders/teradata/tests/system/teradata/script.sql26INSERT INTO {{params.TABLE_NAME}} VALUES (1, 'John Doe', 'IT');
LOW…oviders/teradata/tests/system/teradata/example_bteq.py87 INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT');
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py45 "from": {"email": "foo@bar.com"},
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py58 "email": "foo@bar.com",
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py68 @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com")
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py100 @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com", SENDGRID_MAIL_SENDER="Foo")
LOW…/edge3/tests/unit/edge3/worker_api/routes/test_logs.py62 log_chunk_data="This is Lorem Ipsum log data", log_chunk_time=timezone.utcnow()
LOW…/edge3/tests/unit/edge3/worker_api/routes/test_logs.py81 assert "Lorem Ipsum" in logs[0].log_chunk_data
LOWproviders/trino/tests/unit/trino/hooks/test_trino.py580 {"login": "user@example.com", "password": "p@ss:word", "host": "localhost", "schema": "hive"},
LOW…/system/google/cloud/dataflow/example_dataflow_yaml.py83 "('John Doe', 900, 'USA'), "
LOW…ers/pgvector/tests/system/pgvector/example_pgvector.py62 f"VALUES ('John Doe', 123, '[1.0, 2.0, 3.0]')",
LOW…ector/tests/system/pgvector/example_pgvector_openai.py75 f"VALUES ('John Doe', '123' ,'{embedd_query.output}')",
LOW…cks/tests/unit/databricks/operators/test_databricks.py160 "name": "John Doe",
LOW…che/spark/tests/system/apache/spark/example_pyspark.py52 (1, "John Doe", 21),
LOW…che/spark/tests/system/apache/spark/example_pyspark.py53 (2, "Jane Doe", 22),
LOWchart/values.schema.json6302 "default": "admin@example.com"
LOW…t/tests/helm_tests/airflow_aux/test_create_user_job.py359 "admin@example.com",
LOW…rt/tests/helm_tests/airflow_aux/test_airflow_common.py474 {"host": "example.com", "user": "user", "pass": "pass", "email": "user@example.com"},
LOW…rt/tests/helm_tests/airflow_aux/test_airflow_common.py482 {"host": "example.com", "user": "user", "pass": "pass", "email": "user@example.com"},
LOW…pi_fastapi/core_api/routes/public/test_import_error.py46STACKTRACE3 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit."
LOW…pi_fastapi/core_api/routes/public/test_import_error.py46STACKTRACE3 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit."
LOW…airflow/ui/src/components/DataTable/DataTable.test.tsx38const data = [{ name: "John Doe" }, { name: "Jane Doe" }];
LOW…airflow/ui/src/components/DataTable/DataTable.test.tsx38const data = [{ name: "John Doe" }, { name: "Jane Doe" }];
LOW…airflow/ui/src/components/DataTable/DataTable.test.tsx63 expect(screen.getByText("John Doe")).toBeInTheDocument();
LOW…airflow/ui/src/components/DataTable/DataTable.test.tsx64 expect(screen.getByText("Jane Doe")).toBeInTheDocument();
LOW…airflow/ui/src/components/DataTable/DataTable.test.tsx71 data={[{ name: "John Doe" }]}
LOW…airflow/ui/src/components/DataTable/DataTable.test.tsx89 data={[{ name: "John Doe" }]}
Dead Code17 hits · 34 pts
SeverityFileLineSnippet
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1422
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1616
MEDIUM…ers/standard/tests/unit/standard/triggers/test_file.py260
MEDIUMairflow-core/tests/unit/triggers/test_shared_stream.py183
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1228
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py622
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py693
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py709
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py735
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py908
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py925
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1266
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1313
MEDIUMairflow-core/tests/unit/models/test_dagrun.py3508
MEDIUMairflow-core/src/airflow/triggers/base.py186
MEDIUMairflow-core/src/airflow/triggers/base.py373
MEDIUMairflow-core/src/airflow/triggers/base.py390
Synthetic Comment Markers2 hits · 8 pts
SeverityFileLineSnippet
HIGH…rc/airflow/providers/edge3/example_dags/win_notepad.py72 "This is a text as proposal generated by Airflow DAG. Change it and save and it will get to XCom.",
HIGH…cncf/kubernetes/executors/kubernetes_executor_utils.py751 :param kube_config: The KubeConfig class generated by airflow that contains all kube metadata
Example Usage Blocks2 hits · 3 pts
SeverityFileLineSnippet
LOWdev/prune_old_dirs.py22# Usage:
LOWdev/sync_fork.sh28# Usage: