Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
This report presents the forensic synthetic code analysis of apache/airflow, a Python project with 46,111 GitHub stars. SynthScan v2.0 examined 2,017,942 lines of code across 10277 source files, recording 43508 pattern matches distributed across 25 syntactic categories. The overall adjusted score of 24.2 places this repository in the Moderate AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 43508 distinct pattern matches across 25 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | clients/python/README.md | 297 | def get_airflow_client_access_token( | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 85 | def _copy_elasticsearch_files(tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 111 | def _setup_elasticsearch_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 126 | def _setup_opensearch_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 157 | def _write_providers_mount_override(tmp_dir: Path, providers: list[str]) -> list[str]: | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 185 | def _setup_event_driven_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 234 | def _setup_xcom_object_storage_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 284 | def _run_java_sdk_gradle_container(workdir, *gradle_argv, capture_output=False): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 344 | def _setup_java_sdk_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 471 | def _setup_go_sdk_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 571 | def _setup_openlineage_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 586 | def spin_up_airflow_environment(tmp_path_factory: pytest.TempPathFactory): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 698 | def pytest_runtest_makereport(item, call): | CODE |
| LOW | …2e_tests/e2e_test_utils/base_remote_log_search_test.py | 112 | def test_remote_logging_error_detail(self): | CODE |
| LOW | …ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py | 46 | def create_request_session_with_retries(status_forcelist: list[int]): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 80 | def test_java_tasks_execute_successfully(self, dag_id: str): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 115 | def test_transform_xcom_is_numeric_timestamp(self): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 143 | def test_concurrent_client_calls_succeed(self): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 168 | def test_numeric_xcom_casting(self): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 194 | def test_load_retried_then_succeeded(self): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 228 | def _wait_for_transform_log_record( | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 251 | def test_application_logs_preserve_their_level(self): | CODE |
| LOW | …ests/tests/airflow_e2e_tests/dags/example_xcom_test.py | 56 | def pull_value_from_bash_push(ti=None): | CODE |
| LOW | …_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py | 77 | def test_concurrent_faster_than_sequential(completed_run: _CompletedRun): | CODE |
| LOW | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 161 | def test_load_retried_then_succeeded(completed_run: _CompletedRun): | CODE |
| LOW | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 187 | def test_extract_xcom_has_go_version_and_int_timestamp(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 203 | def test_xcom_crosses_go_to_python(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 208 | def test_extract_logs_show_beep_loop(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 216 | def test_extract_logs_show_runtime_context(completed_run: _CompletedRun): | CODE |
| LOW | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 259 | def test_transform_logs_show_variable_read(completed_run: _CompletedRun): | CODE |
| LOW | …ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py | 62 | def test_all_openlineage_dags_succeed(compose_instance, airflow_dags_path, airflow_logs_path): | CODE |
| LOW | …s/tests/airflow_e2e_tests/openlineage_tests/harness.py | 56 | def discover_expected_dag_ids(dags_folder: Path) -> set[str]: | CODE |
| LOW | …s/tests/airflow_e2e_tests/openlineage_tests/harness.py | 122 | def wait_for_dag_run_to_complete(self, dag_id: str, run_id: str, timeout: int = 300) -> str: | CODE |
| LOW | …flow_e2e_tests/event_driven_tests/test_event_driven.py | 52 | def _wait_for_kafka_consumer_group(self, compose_instance, timeout: int = 60, check_interval: int = 3): | CODE |
| LOW | …flow_e2e_tests/event_driven_tests/test_event_driven.py | 73 | def _wait_for_consumer_dag_runs( | CODE |
| LOW | …flow_e2e_tests/event_driven_tests/test_event_driven.py | 138 | def test_producer_triggers_consumer_and_kafka_offsets(self, compose_instance): | CODE |
| LOW | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 58 | def test_integration_run_dag_task_mapping(self): | CODE |
| LOW | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 82 | def test_integration_run_dag_with_scheduler_failure(self): | CODE |
| LOW | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 112 | def test_pod_failure_logging_with_container_terminated(self, mock_log): | CODE |
| LOW⚡ | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 173 | def test_pod_failure_logging_exception_handling(self, mock_log): | CODE |
| LOW⚡ | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 209 | def test_pod_failure_logging_non_failed_state(self, mock_log): | CODE |
| LOW | kubernetes-tests/tests/kubernetes_tests/conftest.py | 27 | def initialize_providers_manager(): | CODE |
| LOW | kubernetes-tests/tests/kubernetes_tests/conftest.py | 44 | def create_connection_without_db(monkeypatch): | CODE |
| LOW | …s-tests/tests/kubernetes_tests/test_other_executors.py | 52 | def test_integration_run_dag_with_scheduler_failure(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 180 | def test_do_xcom_push_defaults_false(self, kubeconfig_path, tmp_path): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 268 | def test_skip_on_specified_exit_code(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 284 | def test_already_checked_on_success(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 306 | def test_already_checked_on_failure(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 624 | def test_disable_privilege_escalation(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 666 | def test_faulty_service_account(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 755 | def test_pod_template_file_system(self, basic_pod_template): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 778 | def test_pod_template_file_with_overrides_system(self, env_vars, test_label, basic_pod_template): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 805 | def test_pod_template_file_with_full_pod_spec(self, test_label, basic_pod_template): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 1068 | def test_pod_priority_class_name(self, hook_mock, await_pod_completion_mock): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 1158 | def test_reattach_failing_pod_once(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 1225 | def test_changing_base_container_name_with_get_logs(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 1250 | def test_changing_base_container_name_no_logs(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 1280 | def test_changing_base_container_name_no_logs_long(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 1311 | def test_changing_base_container_name_failure(self): | CODE |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 1338 | def test_base_container_name_init_precedence(self): | CODE |
| 22807 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .asf.yaml | 81 | COMMENT | |
| LOW | codecov.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .pre-commit-config.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .hadolint.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | pyproject.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | pyproject.toml | 901 | # Deprecated imports | COMMENT |
| LOW | .readthedocs.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .gitpod.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | yamllint-config.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .markdownlint.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .cherry_picker.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | clients/python/pyproject.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | clients/python/test_python_client.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | clients/python/test_python_client.py | 41 | except ImportError: | COMMENT |
| LOW | airflow-e2e-tests/.pre-commit-config.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/pyproject.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/kafka.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/go.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/localstack.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/Dockerfile.java | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/java.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/openlineage.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/openlineage.yml | 21 | # openlineage_tests/prepare_dags.py (conftest._setup_openlineage_integration). They emit through the | COMMENT |
| LOW | airflow-e2e-tests/docker/openlineage.yml | 41 | AIRFLOW__OPENLINEAGE__EXECUTION_TIMEOUT: '60' | COMMENT |
| LOW | airflow-e2e-tests/docker/opensearch.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/elasticsearch.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/docker/kafka/update_run.sh | 1 | #!/bin/sh | COMMENT |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 481 | without a Go toolchain or any extra runtime installed -- see ``go.yml``. | COMMENT |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/constants.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …2e_tests/e2e_test_utils/base_remote_log_search_test.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …sts/tests/airflow_e2e_tests/e2e_test_utils/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …sts/tests/airflow_e2e_tests/java_sdk_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …s/tests/airflow_e2e_tests/dags/example_event_driven.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …s/tests/airflow_e2e_tests/dags/example_event_driven.py | 41 | # "extra": { | COMMENT |
| LOW | …ests/tests/airflow_e2e_tests/dags/example_xcom_test.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …asticsearch_tests/test_remote_logging_elasticsearch.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …w_e2e_tests/remote_log_elasticsearch_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …tests/tests/airflow_e2e_tests/go_sdk_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ject_storage_tests/test_xcom_object_storage_backend.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …irflow_e2e_tests/xcom_object_storage_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …s/tests/airflow_e2e_tests/remote_log_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …flow_e2e_tests/remote_log_tests/test_remote_logging.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …s/tests/airflow_e2e_tests/openlineage_tests/harness.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …tests/airflow_e2e_tests/openlineage_tests/task_logs.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …/tests/airflow_e2e_tests/openlineage_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …openlineage_tests/dags_extra/openlineage_warmup_dag.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …s/openlineage_tests/dags_extra/e2e_versioned_bundle.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …tests/airflow_e2e_tests/event_driven_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …flow_e2e_tests/event_driven_tests/test_event_driven.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …flow_e2e_tests/remote_log_opensearch_tests/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …log_opensearch_tests/test_remote_logging_opensearch.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| 8363 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | clients/python/test_python_client.py | 27 | CODE | |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 17 | CODE | |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/constants.py | 17 | CODE | |
| LOW | …2e_tests/e2e_test_utils/base_remote_log_search_test.py | 17 | CODE | |
| LOW | …ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py | 17 | CODE | |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 55 | CODE | |
| LOW | …s/tests/airflow_e2e_tests/dags/example_event_driven.py | 18 | CODE | |
| LOW | …ests/tests/airflow_e2e_tests/dags/example_xcom_test.py | 19 | CODE | |
| LOW | …asticsearch_tests/test_remote_logging_elasticsearch.py | 17 | CODE | |
| LOW | …_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py | 24 | CODE | |
| LOW | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 66 | CODE | |
| LOW | …ject_storage_tests/test_xcom_object_storage_backend.py | 17 | CODE | |
| LOW | …flow_e2e_tests/remote_log_tests/test_remote_logging.py | 17 | CODE | |
| LOW | …ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py | 17 | CODE | |
| LOW | …s/tests/airflow_e2e_tests/openlineage_tests/harness.py | 26 | CODE | |
| LOW | …ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py | 31 | CODE | |
| LOW | …tests/airflow_e2e_tests/openlineage_tests/task_logs.py | 26 | CODE | |
| LOW | …openlineage_tests/dags_extra/openlineage_warmup_dag.py | 24 | CODE | |
| LOW | …s/openlineage_tests/dags_extra/e2e_versioned_bundle.py | 31 | CODE | |
| LOW | …flow_e2e_tests/event_driven_tests/test_event_driven.py | 24 | CODE | |
| LOW | …log_opensearch_tests/test_remote_logging_opensearch.py | 17 | CODE | |
| LOW | …sts/airflow_e2e_tests/basic_tests/test_example_dags.py | 18 | CODE | |
| LOW | …low_e2e_tests/basic_tests/test_basic_dag_operations.py | 17 | CODE | |
| LOW | ts-sdk/example/dags/typescript_example.py | 18 | CODE | |
| LOW | ts-sdk/scripts/ci/prek/ts_sdk_lint.py | 18 | CODE | |
| LOW | ts-sdk/scripts/ci/prek/check_supervisor_schema.py | 18 | CODE | |
| LOW | kubernetes-tests/lang_sdk/stage_artifacts.py | 41 | CODE | |
| LOW | kubernetes-tests/lang_sdk/dags/lang_sdk_combined.py | 37 | CODE | |
| LOW | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 17 | CODE | |
| LOW | kubernetes-tests/tests/kubernetes_tests/conftest.py | 17 | CODE | |
| LOW | …s-tests/tests/kubernetes_tests/test_other_executors.py | 17 | CODE | |
| LOW | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 17 | CODE | |
| LOW | …kubernetes_tests/test_lang_sdk_coordinator_executor.py | 30 | CODE | |
| LOW | kubernetes-tests/tests/kubernetes_tests/test_base.py | 17 | CODE | |
| LOW | airflow-ctl/tests/conftest.py | 18 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 18 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_client.py | 18 | CODE | |
| LOW | …w-ctl/tests/airflow_ctl/ctl/test_console_formatting.py | 17 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 18 | CODE | |
| LOW | …ests/airflow_ctl/ctl/commands/test_variable_command.py | 17 | CODE | |
| LOW | …tl/tests/airflow_ctl/ctl/commands/test_pool_command.py | 19 | CODE | |
| LOW | …s/airflow_ctl/ctl/commands/test_connections_command.py | 17 | CODE | |
| LOW | …/tests/airflow_ctl/ctl/commands/test_config_command.py | 17 | CODE | |
| LOW | …tests/airflow_ctl/ctl/commands/test_version_command.py | 17 | CODE | |
| LOW | …ctl/tests/airflow_ctl/ctl/commands/test_dag_command.py | 17 | CODE | |
| LOW | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 17 | CODE | |
| LOW | airflow-ctl/docs/conf.py | 21 | CODE | |
| LOW | …iagrams/airflowctl_api_network_architecture_diagram.py | 17 | CODE | |
| LOW | airflow-ctl/src/airflowctl/__init__.py | 18 | CODE | |
| LOW | airflow-ctl/src/airflowctl/exceptions.py | 22 | CODE | |
| LOW | airflow-ctl/src/airflowctl/__main__.py | 22 | CODE | |
| LOW | airflow-ctl/src/airflowctl/utils/helpers.py | 18 | CODE | |
| LOW | airflow-ctl/src/airflowctl/utils/module_loading.py | 18 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 18 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/operations.py | 18 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/datamodels/generated.py | 5 | CODE | |
| LOW | …ow-ctl/src/airflowctl/api/datamodels/auth_generated.py | 5 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 21 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/__init__.py | 20 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_parser.py | 25 | CODE | |
| 6129 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | airflow-ctl/src/airflowctl/utils/helpers.py | 0 | use a predicate to partition entries into false entries and true entries | STRING |
| HIGH | airflow-core/src/airflow/utils/helpers.py | 0 | use a predicate to partition entries into false entries and true entries | STRING |
| HIGH | devel-common/src/docs/build_docs.py | 0 | use a predicate to partition entries into false entries and true entries | STRING |
| HIGH | airflow-ctl/src/airflowctl/api/datamodels/generated.py | 0 | all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so ple | STRING |
| HIGH | task-sdk/src/airflow/sdk/api/datamodels/_generated.py | 0 | all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so ple | STRING |
| HIGH | airflow-core/src/airflow/utils/state.py | 0 | all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so ple | STRING |
| HIGH | airflow-ctl/src/airflowctl/api/datamodels/generated.py | 0 | all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wi | STRING |
| HIGH | task-sdk/src/airflow/sdk/api/datamodels/_generated.py | 0 | all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wi | STRING |
| HIGH | airflow-core/src/airflow/utils/state.py | 0 | all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wi | STRING |
| HIGH | airflow-ctl/src/airflowctl/api/datamodels/generated.py | 0 | request body for setting an asset state store value. | STRING |
| HIGH | task-sdk/src/airflow/sdk/api/datamodels/_generated.py | 0 | request body for setting an asset state store value. | STRING |
| HIGH | …_fastapi/execution_api/datamodels/asset_state_store.py | 0 | request body for setting an asset state store value. | STRING |
| HIGH | …w/api_fastapi/core_api/datamodels/asset_state_store.py | 0 | request body for setting an asset state store value. | STRING |
| HIGH | airflow-ctl/src/airflowctl/api/datamodels/generated.py | 0 | task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of a | STRING |
| HIGH | …src/airflow/api_fastapi/core_api/datamodels/dag_run.py | 0 | task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of a | STRING |
| HIGH | …flow/api_fastapi/core_api/datamodels/task_instances.py | 0 | task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of a | STRING |
| HIGH | airflow-ctl/src/airflowctl/ctl/utils/yaml.py | 0 | use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly | STRING |
| HIGH | airflow-core/src/airflow/utils/yaml.py | 0 | use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly | STRING |
| HIGH | task-sdk/src/airflow/sdk/yaml.py | 0 | use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly | STRING |
| HIGH | airflow-ctl/src/airflowctl/ctl/utils/yaml.py | 0 | like yaml.safe_load, but use the c libyaml for speed where we can. | STRING |
| HIGH | task-sdk/src/airflow/sdk/yaml.py | 0 | like yaml.safe_load, but use the c libyaml for speed where we can. | STRING |
| HIGH | airflow-core/src/airflow/utils/yaml.py | 0 | like yaml.safe_load, but use the c libyaml for speed where we can. | STRING |
| HIGH | airflow-ctl/src/airflowctl/ctl/utils/yaml.py | 0 | like yaml.safe_dump, but use the c libyaml for speed where we can. | STRING |
| HIGH | task-sdk/src/airflow/sdk/yaml.py | 0 | like yaml.safe_dump, but use the c libyaml for speed where we can. | STRING |
| HIGH | airflow-core/src/airflow/utils/yaml.py | 0 | like yaml.safe_dump, but use the c libyaml for speed where we can. | STRING |
| HIGH | task-sdk/tests/task_sdk/bases/test_operator.py | 0 | class for testing purpose: allows to create objects with custom attributes in one single statement. | STRING |
| HIGH | …elery/tests/integration/celery/test_celery_executor.py | 0 | class for testing purpose: allows to create objects with custom attributes in one single statement. | STRING |
| HIGH | …ore/tests/unit/serialization/test_dag_serialization.py | 0 | class for testing purpose: allows to create objects with custom attributes in one single statement. | STRING |
| HIGH | airflow-core/tests/unit/models/test_renderedtifields.py | 0 | class for testing purpose: allows to create objects with custom attributes in one single statement. | STRING |
| HIGH | task-sdk/tests/task_sdk/definitions/test_callback.py | 0 | used in a number of tests to confirm that deadlines and deadlinealerts function correctly. | STRING |
| HIGH | …re/tests/unit/serialization/test_serialized_objects.py | 0 | used in a number of tests to confirm that deadlines and deadlinealerts function correctly. | STRING |
| HIGH | airflow-core/tests/unit/models/test_dag.py | 0 | used in a number of tests to confirm that deadlines and deadlinealerts function correctly. | STRING |
| HIGH | airflow-core/tests/unit/models/test_deadline.py | 0 | used in a number of tests to confirm that deadlines and deadlinealerts function correctly. | STRING |
| HIGH | airflow-core/tests/unit/models/test_serialized_dag.py | 0 | used in a number of tests to confirm that deadlines and deadlinealerts function correctly. | STRING |
| HIGH | airflow-core/tests/unit/models/test_dagrun.py | 0 | used in a number of tests to confirm that deadlines and deadlinealerts function correctly. | STRING |
| HIGH | task-sdk/src/airflow/sdk/bases/notifier.py | 0 | template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :par | STRING |
| HIGH | task-sdk/src/airflow/sdk/bases/operator.py | 0 | template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :par | STRING |
| HIGH | airflow-core/src/airflow/triggers/base.py | 0 | template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :par | STRING |
| HIGH | task-sdk/src/airflow/sdk/bases/hook.py | 0 | return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbap | STRING |
| HIGH | …/sql/src/airflow/providers/common/sql/operators/sql.py | 0 | return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbap | STRING |
| HIGH | …low/providers/common/sql/operators/generic_transfer.py | 0 | return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbap | STRING |
| HIGH | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 0 | get the previous dag run before the given logical date, optionally filtered by state. | STRING |
| HIGH | task-sdk/src/airflow/sdk/api/client.py | 0 | get the previous dag run before the given logical date, optionally filtered by state. | STRING |
| HIGH | …c/airflow/api_fastapi/execution_api/routes/dag_runs.py | 0 | get the previous dag run before the given logical date, optionally filtered by state. | STRING |
| HIGH | task-sdk/src/airflow/sdk/definitions/deadline.py | 0 | a deadline that calculates the average runtime from past dag runs. | STRING |
| HIGH | …core/src/airflow/serialization/definitions/deadline.py | 0 | a deadline that calculates the average runtime from past dag runs. | STRING |
| HIGH | airflow-core/src/airflow/models/deadline.py | 0 | a deadline that calculates the average runtime from past dag runs. | STRING |
| HIGH | …/airflow/sdk/definitions/_internal/abstractoperator.py | 0 | return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private: | STRING |
| HIGH | …rc/airflow/serialization/definitions/mappedoperator.py | 0 | return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private: | STRING |
| HIGH | …/src/airflow/serialization/definitions/baseoperator.py | 0 | return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private: | STRING |
| HIGH | …/airflow/sdk/definitions/_internal/abstractoperator.py | 0 | get the mapped task group "closest" to this task in the dag. :meta private: | STRING |
| HIGH | …rc/airflow/serialization/definitions/mappedoperator.py | 0 | get the mapped task group "closest" to this task in the dag. :meta private: | STRING |
| HIGH | …/src/airflow/serialization/definitions/baseoperator.py | 0 | get the mapped task group "closest" to this task in the dag. :meta private: | STRING |
| HIGH | …/airflow/sdk/definitions/_internal/abstractoperator.py | 0 | return true if the task is mappedoperator or is in a mapped task group. :meta private: | STRING |
| HIGH | …rc/airflow/serialization/definitions/mappedoperator.py | 0 | return true if the task is mappedoperator or is in a mapped task group. :meta private: | STRING |
| HIGH | …/src/airflow/serialization/definitions/baseoperator.py | 0 | return true if the task is mappedoperator or is in a mapped task group. :meta private: | STRING |
| HIGH | task-sdk/src/airflow/sdk/serde/__init__.py | 0 | return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster than | STRING |
| HIGH | task-sdk/src/airflow/sdk/serde/typing.py | 0 | return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster than | STRING |
| HIGH | airflow-core/src/airflow/serialization/typing.py | 0 | return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster than | STRING |
| HIGH | providers/ftp/src/airflow/providers/ftp/assets/ftp.py | 0 | translate asset with valid aip-60 uri to openlineage with assistance from the hook. | STRING |
| 511 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 257 | # This mirrors org.apache.spark.launcher.JavaModuleOptions.defaultModuleOptions() | COMMENT |
| CRITICAL | airflow-ctl/src/airflowctl/ctl/cli_parser.py | 45 | from airflowctl.utils.helpers import partition | CODE |
| CRITICAL | …tableau/src/airflow/providers/tableau/hooks/tableau.py | 25 | from airflow.utils.helpers import exactly_one | CODE |
| CRITICAL | …unit/amazon/aws/triggers/test_opensearch_serverless.py | 29 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py | 71 | operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator( | CODE |
| CRITICAL | …sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py | 101 | operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator( | CODE |
| CRITICAL | …sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py | 140 | operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator( | CODE |
| CRITICAL | …sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py | 56 | from airflow.utils.helpers import convert_camel_to_snake | CODE |
| CRITICAL | …unit/amazon/aws/executors/batch/test_batch_executor.py | 47 | from airflow.utils.helpers import convert_camel_to_snake | CODE |
| CRITICAL⚡ | …ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py | 182 | mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params) | CODE |
| CRITICAL⚡ | …ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py | 201 | mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params) | CODE |
| CRITICAL⚡ | …oviders/amazon/tests/unit/amazon/aws/hooks/test_dms.py | 453 | mock_conn.return_value.get_waiter.return_value.wait.assert_called_with(**expected_waiter_call_params) | CODE |
| CRITICAL | …oviders/amazon/tests/unit/amazon/aws/hooks/test_eks.py | 100 | from moto.core.exceptions import AWSError | CODE |
| CRITICAL | …rs/amazon/tests/unit/amazon/aws/hooks/test_base_aws.py | 446 | user_agent_dict = dict(tag.split("/") for tag in executor.ecs.meta.config.user_agent.split(" ")) | CODE |
| CRITICAL⚡ | …unit/amazon/aws/hooks/test_sagemaker_unified_studio.py | 113 | self.hook._sagemaker_studio.execution_client.start_execution.assert_called_once() | CODE |
| CRITICAL⚡ | …unit/amazon/aws/hooks/test_sagemaker_unified_studio.py | 124 | self.hook._sagemaker_studio.execution_client.get_execution.assert_called() | CODE |
| CRITICAL | providers/amazon/tests/unit/amazon/aws/hooks/test_s3.py | 357 | hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with( | CODE |
| CRITICAL | providers/amazon/tests/unit/amazon/aws/hooks/test_s3.py | 412 | hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with( | CODE |
| CRITICAL | providers/amazon/tests/unit/amazon/aws/hooks/test_s3.py | 455 | hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with( | CODE |
| CRITICAL | providers/amazon/tests/unit/amazon/aws/hooks/test_s3.py | 512 | hook.resource.Object.return_value.load.assert_called_with( | CODE |
| CRITICAL | …/tests/unit/amazon/aws/auth_manager/avp/test_facade.py | 30 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | providers/amazon/tests/system/amazon/aws/utils/k8s.py | 19 | from airflow.utils.helpers import exactly_one | CODE |
| CRITICAL | …/providers/amazon/aws/sensors/opensearch_serverless.py | 29 | from airflow.utils.helpers import exactly_one | CODE |
| CRITICAL | …c/airflow/providers/amazon/aws/operators/s3_vectors.py | 27 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …azon/src/airflow/providers/amazon/aws/operators/rds.py | 38 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 66 | from airflow.utils.helpers import exactly_one, prune_dict | CODE |
| CRITICAL | …low/providers/amazon/aws/operators/redshift_cluster.py | 39 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …airflow/providers/amazon/aws/operators/glue_catalog.py | 28 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …/airflow/providers/amazon/aws/operators/eventbridge.py | 26 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …flow/providers/amazon/aws/operators/mwaa_serverless.py | 28 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 50 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …roviders/amazon/aws/operators/opensearch_serverless.py | 29 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …rc/airflow/providers/amazon/aws/operators/s3_tables.py | 31 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …mazon/src/airflow/providers/amazon/aws/operators/s3.py | 35 | from airflow.utils.helpers import exactly_one | CODE |
| CRITICAL | …/src/airflow/providers/amazon/aws/operators/bedrock.py | 47 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …azon/src/airflow/providers/amazon/aws/operators/ecs.py | 43 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …providers/amazon/aws/triggers/opensearch_serverless.py | 23 | from airflow.utils.helpers import exactly_one | CODE |
| CRITICAL | …azon/src/airflow/providers/amazon/aws/triggers/base.py | 27 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …zon/src/airflow/providers/amazon/aws/utils/__init__.py | 28 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …rflow/providers/amazon/aws/transfers/dynamodb_to_s3.py | 36 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …viders/amazon/aws/executors/ecs/ecs_executor_config.py | 46 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …low/providers/amazon/aws/executors/ecs/ecs_executor.py | 53 | from airflow.utils.helpers import merge_dicts, prune_dict | CODE |
| CRITICAL | …providers/amazon/aws/executors/batch/batch_executor.py | 38 | from airflow.utils.helpers import merge_dicts, prune_dict | CODE |
| CRITICAL | …rs/amazon/aws/executors/batch/batch_executor_config.py | 42 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …ers/amazon/aws/executors/aws_lambda/lambda_executor.py | 47 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …s/amazon/src/airflow/providers/amazon/aws/links/emr.py | 26 | from airflow.utils.helpers import exactly_one | CODE |
| CRITICAL | …s/amazon/src/airflow/providers/amazon/aws/hooks/sqs.py | 23 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …/src/airflow/providers/amazon/aws/hooks/eventbridge.py | 22 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …/amazon/src/airflow/providers/amazon/aws/hooks/logs.py | 27 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …zon/src/airflow/providers/amazon/aws/hooks/base_aws.py | 60 | from airflow.utils.helpers import exactly_one | CODE |
| CRITICAL | …rs/amazon/src/airflow/providers/amazon/aws/hooks/s3.py | 66 | from airflow.utils.helpers import chunks | CODE |
| CRITICAL | …s/amazon/src/airflow/providers/amazon/aws/hooks/sns.py | 25 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …irflow/providers/amazon/aws/auth_manager/avp/facade.py | 34 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …/src/airflow/providers/amazon/aws/notifications/ses.py | 26 | from airflow.utils.helpers import prune_dict | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 189 | mock_client.secrets.kv.v2.read_secret_version.assert_has_calls( | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 253 | mock_client.secrets.kv.v2.read_secret_version.assert_not_called() | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 347 | mock_client.secrets.kv.v2.read_secret_version.assert_has_calls( | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 442 | mock_client.secrets.kv.v1.read_secret.assert_called_once_with(**expected_args) | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 472 | mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with( | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 781 | mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with( | CODE |
| 202 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 64 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 66 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 170 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 172 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 226 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 228 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 249 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 251 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 268 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 270 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 336 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 338 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 41 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 43 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …low/providers/amazon/aws/executors/ecs/ecs_executor.py | 682 | # ── Back-compat shims for renamed methods/attrs ──────────────────────── | COMMENT |
| MEDIUM | …ders/google/tests/unit/google/cloud/links/test_base.py | 24 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ders/google/tests/unit/google/cloud/links/test_base.py | 26 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 1956 | # ------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 1958 | # ------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ft/winrm/tests/system/microsoft/winrm/example_winrm.py | 24 | # -------------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ft/winrm/tests/system/microsoft/winrm/example_winrm.py | 26 | # -------------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ft/winrm/tests/system/microsoft/winrm/example_winrm.py | 34 | # -------------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ft/winrm/tests/system/microsoft/winrm/example_winrm.py | 37 | # -------------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …azure/tests/unit/microsoft/azure/hooks/test_compute.py | 206 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …azure/tests/unit/microsoft/azure/hooks/test_compute.py | 208 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …src/airflow/providers/microsoft/azure/hooks/compute.py | 172 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …src/airflow/providers/microsoft/azure/hooks/compute.py | 174 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …compat/tests/unit/common/compat/sqlalchemy/test_orm.py | 45 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM | …compat/tests/unit/common/compat/sqlalchemy/test_orm.py | 47 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …compat/tests/unit/common/compat/sqlalchemy/test_orm.py | 72 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …compat/tests/unit/common/compat/sqlalchemy/test_orm.py | 74 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 149 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 151 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 153 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 155 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 163 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 165 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 169 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 171 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 173 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 175 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 186 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 188 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 198 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 200 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 204 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 206 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 208 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 210 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 212 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 214 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 218 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 220 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 224 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 226 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 229 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 231 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 236 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 238 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 240 | # ============================================================================ | COMMENT |
| 562 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 668 | except Exception: | CODE |
| LOW | …ject_storage_tests/test_xcom_object_storage_backend.py | 65 | except Exception as e: | CODE |
| LOW | kubernetes-tests/tests/kubernetes_tests/test_base.py | 163 | except Exception: | CODE |
| LOW | kubernetes-tests/tests/kubernetes_tests/test_base.py | 198 | except Exception as e: | CODE |
| LOW | airflow-ctl/src/airflowctl/ctl/commands/auth_command.py | 85 | except Exception as e: | CODE |
| LOW | airflow-ctl/src/airflowctl/ctl/commands/auth_command.py | 119 | except Exception as e: | CODE |
| LOW | airflow-ctl/src/airflowctl/ctl/commands/auth_command.py | 183 | except Exception as e: | CODE |
| LOW | …-ctl/src/airflowctl/ctl/commands/connection_command.py | 46 | except Exception as e: | CODE |
| LOW | …-ctl/src/airflowctl/ctl/commands/connection_command.py | 73 | except Exception as e: | CODE |
| LOW | airflow-ctl/src/airflowctl/ctl/commands/pool_command.py | 82 | except Exception as e: | CODE |
| LOW | …flow-ctl/src/airflowctl/ctl/commands/config_command.py | 833 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 251 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 258 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 288 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 340 | except Exception: | CODE |
| LOW | …_sdk/execution_time/test_connection_test_supervisor.py | 244 | except Exception as e: | CODE |
| MEDIUM | …_sdk/execution_time/test_connection_test_supervisor.py | 241 | def capture(): | CODE |
| LOW | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 1342 | except Exception as e: | CODE |
| LOW | task-sdk/tests/task_sdk/execution_time/test_comms.py | 165 | except Exception as e: | CODE |
| MEDIUM | task-sdk/tests/task_sdk/execution_time/test_comms.py | 161 | def send_and_store(idx): | CODE |
| LOW | task-sdk/src/airflow/sdk/configuration.py | 159 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/log.py | 236 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/providers_manager_runtime.py | 106 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/providers_manager_runtime.py | 593 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/plugins_manager.py | 94 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/lineage.py | 203 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/timezone.py | 38 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/io/path.py | 161 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/bases/sensor.py | 220 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/bases/notifier.py | 139 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/bases/notifier.py | 153 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/comms.py | 366 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 303 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 394 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 471 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 483 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 920 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 954 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1199 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1391 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1519 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1538 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1643 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 2337 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 2489 | except Exception as e: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2242 | except Exception: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2252 | except Exception: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2260 | except Exception: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2268 | except Exception: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2278 | except Exception: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2285 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1190 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1418 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1430 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1579 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1691 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1780 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1990 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2064 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2229 | except Exception: | CODE |
| 1065 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | clients/python/test_python_client.py | 108 | # Create a DAGRun object (no dag_id should be specified because it is read-only property of DAGRun) | COMMENT |
| MEDIUM | …s/tests/airflow_e2e_tests/dags/example_event_driven.py | 107 | # Define a trigger that listens to an external message queue (Apache Kafka in this case) | COMMENT |
| MEDIUM | …s/tests/airflow_e2e_tests/dags/example_event_driven.py | 118 | # Define an asset that watches for messages on the queue | COMMENT |
| MEDIUM | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 119 | # Create a mock KubernetesExecutor instance | COMMENT |
| MEDIUM | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 136 | # Create a test task key | COMMENT |
| MEDIUM⚡ | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 179 | # Create a mock KubernetesExecutor instance | COMMENT |
| MEDIUM⚡ | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 183 | # Create a test task key | COMMENT |
| MEDIUM⚡ | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 215 | # Create a mock KubernetesExecutor instance | COMMENT |
| MEDIUM⚡ | …sts/tests/kubernetes_tests/test_kubernetes_executor.py | 220 | # Create a test task key | COMMENT |
| MEDIUM | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 231 | # Create a temporary file | COMMENT |
| MEDIUM | …tl/tests/airflow_ctl/ctl/commands/test_pool_command.py | 146 | # Create a proper pool object with dictionary attributes instead of MagicMock | COMMENT |
| MEDIUM | …tl/tests/airflow_ctl/ctl/commands/test_pool_command.py | 159 | # Create a mock response with proper dictionary attributes | COMMENT |
| MEDIUM⚡ | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 341 | # Create a config file | COMMENT |
| MEDIUM⚡ | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 358 | # Create a config file | COMMENT |
| MEDIUM⚡ | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 375 | # Create a config file | COMMENT |
| MEDIUM⚡ | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 394 | # Create a config file | COMMENT |
| MEDIUM⚡ | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 411 | # Create a config file | COMMENT |
| MEDIUM⚡ | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 428 | # Create a corrupted config file | COMMENT |
| MEDIUM⚡ | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 442 | # Create a config file | COMMENT |
| MEDIUM | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 293 | # Create a config file | COMMENT |
| MEDIUM | task-sdk/tests/task_sdk/test_lineage.py | 722 | # Create a large value | COMMENT |
| MEDIUM | task-sdk/tests/task_sdk/test_lineage.py | 778 | # Create a non-serializable object | COMMENT |
| MEDIUM⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 836 | # Create a directory that exists | COMMENT |
| MEDIUM⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 840 | # Create a mock bundle instance | COMMENT |
| MEDIUM | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 858 | # Create a directory with read permissions | COMMENT |
| MEDIUM | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 778 | # Create a mock client to assert calls to the client | COMMENT |
| MEDIUM | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 1233 | # Create a fake placeholder in the open socket weakref | COMMENT |
| MEDIUM | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 3496 | # Create a simple TaskInstance datamodel to pass to the supervisor | COMMENT |
| MEDIUM | task-sdk/tests/task_sdk/definitions/test_dag.py | 336 | # Create a linear chain: t1 -> t2 -> t3 -> t4 -> t5 | COMMENT |
| MEDIUM | task-sdk/tests/task_sdk/definitions/test_dag.py | 371 | # Create a diamond pattern: | COMMENT |
| MEDIUM | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 810 | # Create a mapped task within the task group | COMMENT |
| MEDIUM | task-sdk/dev/datamodel_code_formatter.py | 109 | # Create a replacement for 'Tasks' -> 'tuple[str, int]' | COMMENT |
| MEDIUM | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 2090 | # Create a socketpair preemptively, in case the task process runs VirtualEnv operator or run_as_user | COMMENT |
| MEDIUM | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 2143 | # Create a minimal supervisor instance for trigger execution | COMMENT |
| MEDIUM | …sdk/src/airflow/sdk/execution_time/execute_workload.py | 66 | # Create a mutually exclusive group to ensure that only one of the flags is set | COMMENT |
| MEDIUM | task-sdk/src/airflow/sdk/api/client.py | 309 | # Create a deferred state payload from msg | COMMENT |
| MEDIUM | task-sdk/src/airflow/sdk/api/client.py | 321 | # Create a reschedule state payload from msg | COMMENT |
| MEDIUM | providers-summary-docs/conf.py | 26 | # This file is execfile()d with the current directory set to its | COMMENT |
| MEDIUM | …ders/presto/tests/unit/presto/hooks/test_presto_sql.py | 149 | # Create a real Airflow connection | COMMENT |
| MEDIUM | …it/amazon/aws/sensors/test_sagemaker_unified_studio.py | 91 | # Create the sensor | COMMENT |
| MEDIUM | …ers/amazon/tests/unit/amazon/aws/operators/test_eks.py | 1034 | # Create a temporary credentials file | COMMENT |
| MEDIUM | …ers/amazon/tests/unit/amazon/aws/operators/test_eks.py | 1093 | # Create a temporary credentials file | COMMENT |
| MEDIUM | …/amazon/aws/operators/test_sagemaker_unified_studio.py | 141 | # Create the operator | COMMENT |
| MEDIUM | …/amazon/aws/operators/test_sagemaker_unified_studio.py | 189 | # Create the operator with wait_for_completion set to True | COMMENT |
| MEDIUM | …/amazon/aws/operators/test_sagemaker_unified_studio.py | 239 | # Create the operator with wait_for_completion set to False | COMMENT |
| MEDIUM | …zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py | 173 | # Create a test file remotely | COMMENT |
| MEDIUM | …sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py | 183 | # Create a new Collection and verify it is empty. | COMMENT |
| MEDIUM | …sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py | 275 | # Create a new Collection and add a two tasks. | COMMENT |
| MEDIUM | …mazon/aws/executors/aws_lambda/test_lambda_executor.py | 1211 | # Create a team-specific executor. | COMMENT |
| MEDIUM | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 107 | # Create the local log file structure | COMMENT |
| MEDIUM | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 154 | # Create a logger factory and pass in the file path we want it to use | COMMENT |
| MEDIUM | …viders/amazon/tests/unit/amazon/aws/bundles/test_s3.py | 195 | # Create a pytest Call object to compare against the call_args_list of the _log.debug mock | COMMENT |
| MEDIUM | …ders/amazon/tests/system/amazon/aws/example_bedrock.py | 65 | # Creating a custom model takes nearly two hours. If SKIP_LONG_TASKS | COMMENT |
| MEDIUM | …tests/system/amazon/aws/example_eks_with_nodegroups.py | 94 | # Create an Amazon EKS Cluster control plane without attaching compute service. | COMMENT |
| MEDIUM | …ers/amazon/tests/system/amazon/aws/example_datasync.py | 184 | # Create a task (the task does not exist) | COMMENT |
| MEDIUM | …/system/amazon/aws/example_eks_with_fargate_profile.py | 78 | # Create an Amazon EKS Cluster control plane without attaching a compute service. | COMMENT |
| MEDIUM | …m/amazon/aws/example_eks_with_nodegroup_in_one_step.py | 92 | # Create an Amazon EKS cluster control plane and an EKS nodegroup compute platform in one step. | COMMENT |
| MEDIUM | providers/amazon/tests/system/amazon/aws/example_ec2.py | 62 | # Creating the key takes a very short but measurable time, preventing race condition: | COMMENT |
| MEDIUM | …azon/tests/system/amazon/aws/example_dms_serverless.py | 118 | # Create the Table. | COMMENT |
| MEDIUM | …azon/tests/system/amazon/aws/example_step_functions.py | 57 | # Create a Step Functions State Machine and return the ARN for use by | COMMENT |
| 222 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 586 | CODE | |
| LOW | kubernetes-tests/tests/kubernetes_tests/test_base.py | 245 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 217 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 608 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 789 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 199 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 250 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/operations.py | 167 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 858 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 430 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 624 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 703 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 707 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/commands/auth_command.py | 124 | CODE | |
| LOW | …flow-ctl/src/airflowctl/ctl/commands/config_command.py | 729 | CODE | |
| LOW | …flow-ctl/src/airflowctl/ctl/commands/config_command.py | 105 | CODE | |
| LOW | task-sdk/tests/conftest.py | 178 | CODE | |
| LOW | …k-sdk/tests/task_sdk/test_providers_manager_runtime.py | 182 | CODE | |
| LOW | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 5663 | CODE | |
| LOW | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 3552 | CODE | |
| LOW | task-sdk/tests/task_sdk/definitions/test_taskgroup.py | 218 | CODE | |
| LOW | task-sdk/tests/task_sdk/definitions/test_taskgroup.py | 567 | CODE | |
| LOW | task-sdk/tests/task_sdk/definitions/test_taskgroup.py | 993 | CODE | |
| LOW | task-sdk/tests/task_sdk/definitions/test_taskgroup.py | 1006 | CODE | |
| LOW | task-sdk/tests/task_sdk/definitions/test_taskgroup.py | 1010 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 441 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 496 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 610 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 463 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 515 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 650 | CODE | |
| LOW | task-sdk/src/airflow/sdk/configuration.py | 211 | CODE | |
| LOW | task-sdk/src/airflow/sdk/providers_manager_runtime.py | 251 | CODE | |
| LOW | task-sdk/src/airflow/sdk/providers_manager_runtime.py | 305 | CODE | |
| LOW | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 70 | CODE | |
| LOW | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 157 | CODE | |
| LOW | task-sdk/src/airflow/sdk/io/fs.py | 52 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/sensor.py | 183 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/resumablejobmixin.py | 103 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/decorator.py | 279 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/operator.py | 2005 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 680 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1010 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1131 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1469 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1689 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 957 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1362 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1375 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1513 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2210 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2305 | CODE | |
| LOW | …/src/airflow/sdk/execution_time/callback_supervisor.py | 349 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 320 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 1369 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 852 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 1218 | CODE | |
| LOW | …-sdk/src/airflow/sdk/execution_time/schema/__init__.py | 73 | CODE | |
| LOW | task-sdk/src/airflow/sdk/definitions/mappedoperator.py | 117 | CODE | |
| LOW | task-sdk/src/airflow/sdk/definitions/xcom_arg.py | 100 | CODE | |
| 879 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …tests/kubernetes_tests/test_kubernetes_pod_operator.py | 546 | 'echo "retrieved from mount" > /tmp/test_volume/test.txt && cat /tmp/test_volume/test.txt' | CODE |
| HIGH⚡ | task-sdk/tests/task_sdk/api/test_client.py | 772 | # Return None (null) when no previous TI found | COMMENT |
| HIGH⚡ | task-sdk/tests/task_sdk/api/test_client.py | 1602 | # Return None (null) when no previous Dag run found | COMMENT |
| HIGH | task-sdk/tests/task_sdk/serde/test_serializers.py | 282 | assert i.equals(d) | CODE |
| HIGH | task-sdk/src/airflow/sdk/bases/operator.py | 1533 | DagContext.push(None) | CODE |
| HIGH | task-sdk/src/airflow/sdk/definitions/dag.py | 751 | DagContext.push(self) | CODE |
| HIGH | task-sdk/src/airflow/sdk/definitions/taskgroup.py | 393 | TaskGroupContext.push(self) | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 139 | assert read_df.equals(test_df) | CODE |
| HIGH⚡ | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 238 | assert df.equals( | CODE |
| HIGH⚡ | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 248 | assert df.equals( | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 290 | assert df.equals( | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 332 | assert df.equals( | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 342 | assert df.equals( | CODE |
| HIGH | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 500 | '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}', | STRING |
| HIGH | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 510 | '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}', | STRING |
| HIGH⚡ | providers/amazon/tests/system/amazon/aws/example_ssm.py | 59 | if command -v yum &> /dev/null; then | CODE |
| HIGH⚡ | providers/amazon/tests/system/amazon/aws/example_ssm.py | 61 | elif command -v dnf &> /dev/null; then | CODE |
| HIGH⚡ | providers/amazon/tests/system/amazon/aws/example_ssm.py | 69 | if ! command -v amazon-ssm-agent &> /dev/null; then | CODE |
| HIGH⚡ | …irflow/providers/amazon/aws/secrets/systems_manager.py | 40 | backend_kwargs = {"connections_prefix": "/airflow/connections", "profile_name": null} | STRING |
| HIGH⚡ | …irflow/providers/amazon/aws/secrets/systems_manager.py | 48 | If set to None (null), requests for connections will not be sent to AWS SSM Parameter Store. | STRING |
| HIGH⚡ | …irflow/providers/amazon/aws/secrets/systems_manager.py | 54 | If set to None (null), requests for variables will not be sent to AWS SSM Parameter Store. | STRING |
| HIGH⚡ | …irflow/providers/amazon/aws/secrets/systems_manager.py | 60 | If set to None (null), requests for configurations will not be sent to AWS SSM Parameter Store. | STRING |
| HIGH | …mazon/src/airflow/providers/amazon/aws/hooks/athena.py | 258 | self.log.error("Invalid Query state (null). Query execution id: %s", query_execution_id) | CODE |
| HIGH⚡ | …s/teradata/tests/unit/teradata/utils/test_bteq_util.py | 94 | ssh_client.exec_command.assert_called_once_with("uname || ver") | CODE |
| HIGH | …s/teradata/tests/unit/teradata/utils/test_bteq_util.py | 52 | ssh_client.exec_command.assert_called_once_with("uname || ver") | CODE |
| HIGH | …s/teradata/tests/unit/teradata/utils/test_bteq_util.py | 66 | ssh_client.exec_command.assert_called_once_with("uname || ver") | CODE |
| HIGH | …s/teradata/tests/unit/teradata/utils/test_bteq_util.py | 80 | ssh_client.exec_command.assert_called_once_with("uname || ver") | CODE |
| HIGH⚡ | …data/src/airflow/providers/teradata/utils/bteq_util.py | 32 | stdin, stdout, stderr = ssh_client.exec_command("uname || ver") | CODE |
| HIGH⚡ | …adata/src/airflow/providers/teradata/utils/tpt_util.py | 132 | f"dd if=/dev/zero of={file_path} bs=4096 count=$(($(stat -c '%s' {file_path})/4096+1)) 2>/dev/nu | CODE |
| HIGH⚡ | …icorp/src/airflow/providers/hashicorp/secrets/vault.py | 51 | (default: 'connections'). If set to None (null), requests for connections will not be sent to Vault. | STRING |
| HIGH⚡ | …icorp/src/airflow/providers/hashicorp/secrets/vault.py | 53 | (default: 'variables'). If set to None (null), requests for variables will not be sent to Vault. | STRING |
| HIGH⚡ | …icorp/src/airflow/providers/hashicorp/secrets/vault.py | 55 | (default: 'config'). If set to None (null), requests for configurations will not be sent to Vault. | STRING |
| HIGH | …ts/unit/google/cloud/transfers/test_postgres_to_gcs.py | 44 | b'{"some_json": {"firtname": "John", "lastname": "Smith", "nested_dict": {"a": null, "b": "something"}}, "some_num": | CODE |
| HIGH | …ts/unit/google/cloud/transfers/test_postgres_to_gcs.py | 73 | "nested_dict": {"a": null, "b": "something"}}', | CODE |
| HIGH | …tests/unit/google/cloud/transfers/test_mssql_to_gcs.py | 298 | assert schema.field("some_binary").type.equals(pyarrow.bool_()) | CODE |
| HIGH | …tests/unit/google/cloud/transfers/test_mssql_to_gcs.py | 299 | assert schema.field("some_bit").type.equals(pyarrow.bool_()) | CODE |
| HIGH | …e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py | 398 | assert df.equals(OUTPUT_DF) | CODE |
| HIGH | …e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py | 420 | assert df.equals(OUTPUT_DF) | CODE |
| HIGH | …e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py | 442 | assert df.equals(OUTPUT_DF) | CODE |
| HIGH | …e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py | 472 | assert df.equals(output_df) | CODE |
| HIGH | …e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py | 501 | assert df.equals(OUTPUT_DF_WITH_EXCLUDE_COLUMNS) | CODE |
| HIGH | …e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py | 529 | assert concat_df.equals(OUTPUT_DF) | CODE |
| HIGH⚡ | …system/google/cloud/cloud_build/example_cloud_build.py | 69 | "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}], | CODE |
| HIGH⚡ | …system/google/cloud/cloud_build/example_cloud_build.py | 76 | "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}], | CODE |
| HIGH⚡ | …system/google/cloud/cloud_build/example_cloud_build.py | 82 | "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 300"]}], | CODE |
| HIGH | …oogle/tests/system/google/cloud/ray/example_ray_job.py | 93 | entrypoint="echo hi && sleep 105 && echo hi2", | CODE |
| HIGH | …s/google/src/airflow/providers/google/ads/hooks/ads.py | 57 | "json_key_file_path": null, | STRING |
| HIGH⚡ | …rflow/providers/google/cloud/secrets/secret_manager.py | 64 | If set to None (null), requests for connections will not be sent to GCP Secrets Manager | STRING |
| HIGH⚡ | …rflow/providers/google/cloud/secrets/secret_manager.py | 66 | If set to None (null), requests for variables will not be sent to GCP Secrets Manager | STRING |
| HIGH⚡ | …rflow/providers/google/cloud/secrets/secret_manager.py | 69 | If set to None (null), requests for configurations will not be sent to GCP Secrets Manager | STRING |
| HIGH⚡ | …airflow/providers/microsoft/azure/secrets/key_vault.py | 71 | If set to None (null), requests for connections will not be sent to Azure Key Vault | STRING |
| HIGH⚡ | …airflow/providers/microsoft/azure/secrets/key_vault.py | 73 | If set to None (null), requests for variables will not be sent to Azure Key Vault | STRING |
| HIGH⚡ | …airflow/providers/microsoft/azure/secrets/key_vault.py | 75 | If set to None (null), requests for configurations will not be sent to Azure Key Vault | STRING |
| HIGH | …s/standard/tests/unit/standard/decorators/test_bash.py | 152 | assert bash_task.operator.bash_command == "echo hello world && echo 2" | CODE |
| HIGH | …s/standard/tests/unit/standard/decorators/test_bash.py | 155 | self.validate_bash_command_rtif(ti, "echo hello world && echo 2") | CODE |
| HIGH | …/sql/src/airflow/providers/common/sql/operators/sql.py | 1606 | self.push(meta_data) | CODE |
| HIGH⚡ | providers/ssh/tests/unit/ssh/utils/test_remote_job.py | 355 | subprocess.run(["bash", "-c", f"kill -9 -{pgid} 2>/dev/null || true"], check=False) | CODE |
| HIGH⚡ | providers/ssh/tests/unit/ssh/utils/test_remote_job.py | 356 | subprocess.run(["bash", "-c", f"pkill -9 -f '{marker}' 2>/dev/null || true"], check=False) | CODE |
| HIGH⚡ | …ders/ssh/src/airflow/providers/ssh/utils/remote_job.py | 353 | return f"stat -c%s '{file_path}' 2>/dev/null || stat -f%z '{file_path}' 2>/dev/null || echo 0" | CODE |
| HIGH⚡ | …ders/ssh/src/airflow/providers/ssh/utils/remote_job.py | 425 | f'if [ "$p" -gt 1 ] 2>/dev/null; then ' | CODE |
| 72 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py | 216 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/operations.py | 627 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 131 | CODE | |
| LOW | task-sdk/tests/conftest.py | 220 | CODE | |
| LOW | task-sdk/tests/conftest.py | 240 | CODE | |
| LOW | task-sdk/tests/conftest.py | 263 | CODE | |
| LOW | task-sdk/tests/conftest.py | 306 | CODE | |
| LOW | …s/task_sdk/coordinators/executable/test_coordinator.py | 67 | CODE | |
| LOW | task-sdk/dev/datamodel_code_formatter.py | 144 | CODE | |
| LOW | task-sdk/src/airflow/sdk/io/path.py | 61 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/sensor.py | 115 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/decorator.py | 441 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/operator.py | 277 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/operator.py | 1029 | CODE | |
| LOW | task-sdk/src/airflow/sdk/api/client.py | 852 | CODE | |
| LOW | task-sdk/src/airflow/sdk/definitions/dag.py | 1606 | CODE | |
| LOW | task-sdk/src/airflow/sdk/definitions/connection.py | 130 | CODE | |
| LOW | …k/src/airflow/sdk/definitions/decorators/task_group.py | 194 | CODE | |
| LOW | …src/airflow/providers/papermill/operators/papermill.py | 75 | CODE | |
| LOW | …ocker/src/airflow/providers/docker/operators/docker.py | 227 | CODE | |
| LOW | …src/airflow/providers/docker/operators/docker_swarm.py | 126 | CODE | |
| LOW | …src/airflow/providers/discord/hooks/discord_webhook.py | 186 | CODE | |
| LOW | …src/airflow/providers/discord/hooks/discord_webhook.py | 287 | CODE | |
| LOW | …eau/src/airflow/providers/tableau/operators/tableau.py | 87 | CODE | |
| LOW | …amazon/src/airflow/providers/amazon/aws/sensors/sqs.py | 95 | CODE | |
| LOW | …amazon/src/airflow/providers/amazon/aws/sensors/sqs.py | 183 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/rds.py | 187 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/dms.py | 179 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/dms.py | 772 | CODE | |
| LOW | …iders/amazon/aws/operators/sagemaker_unified_studio.py | 115 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/ses.py | 82 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 121 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 265 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 518 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 728 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 1271 | CODE | |
| LOW | …low/providers/amazon/aws/operators/redshift_cluster.py | 159 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/eks.py | 80 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/eks.py | 270 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/eks.py | 522 | CODE | |
| LOW | …on/src/airflow/providers/amazon/aws/operators/batch.py | 149 | CODE | |
| LOW | …ow/providers/amazon/aws/operators/neptune_analytics.py | 101 | CODE | |
| LOW | …ow/providers/amazon/aws/operators/neptune_analytics.py | 604 | CODE | |
| LOW | …ow/providers/amazon/aws/operators/neptune_analytics.py | 839 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/mwaa.py | 89 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/glue.py | 127 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/glue.py | 522 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/glue.py | 684 | CODE | |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 281 | CODE | |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 782 | CODE | |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 1212 | CODE | |
| LOW | …zon/aws/operators/sagemaker_unified_studio_notebook.py | 108 | CODE | |
| LOW | …src/airflow/providers/amazon/aws/operators/datasync.py | 136 | CODE | |
| LOW | …n/src/airflow/providers/amazon/aws/operators/athena.py | 87 | CODE | |
| LOW | …mazon/src/airflow/providers/amazon/aws/operators/s3.py | 823 | CODE | |
| LOW | …irflow/providers/amazon/aws/operators/redshift_data.py | 117 | CODE | |
| LOW | …flow/providers/amazon/aws/operators/lambda_function.py | 77 | CODE | |
| LOW | …/src/airflow/providers/amazon/aws/operators/bedrock.py | 712 | CODE | |
| LOW | …/src/airflow/providers/amazon/aws/operators/bedrock.py | 1366 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/ecs.py | 437 | CODE | |
| 643 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-ctl/src/airflowctl/api/client.py | 83 | __all__ = [ | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/__init__.py | 24 | __all__ = ["console"] | CODE |
| LOW | task-sdk/src/airflow/sdk/__init__.py | 21 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/types.py | 28 | __all__ = ["TaskInstance", "TaskInstanceKey"] | CODE |
| LOW | task-sdk/src/airflow/sdk/timezone.py | 41 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/listener.py | 45 | __all__ = ["get_listener_manager", "ListenerManager"] | CODE |
| LOW | …dk/src/airflow/sdk/coordinators/executable/__init__.py | 23 | __all__ = ["ExecutableCoordinator", "__version__"] | CODE |
| LOW | task-sdk/src/airflow/sdk/coordinators/java/__init__.py | 27 | __all__ = ["JavaCoordinator"] | CODE |
| LOW | task-sdk/src/airflow/sdk/coordinators/node/__init__.py | 28 | __all__ = ["NodeCoordinator"] | CODE |
| LOW | task-sdk/src/airflow/sdk/io/__init__.py | 25 | __all__ = ["ObjectStoragePath", "attach", "get_fs", "has_fs", "Properties"] | CODE |
| LOW | task-sdk/src/airflow/sdk/bases/operator.py | 106 | __all__ = [ | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/bases/operator.py | 1433 | def _set_xcomargs_dependencies(self) -> None: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/bases/operator.py | 1441 | def _set_xcomargs_dependency(self, field: str, newvalue: Any) -> None: | CODE |
| LOW | task-sdk/src/airflow/sdk/observability/__init__.py | 21 | __all__ = ["trace"] | CODE |
| LOW | task-sdk/src/airflow/sdk/observability/stats.py | 33 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/coordinator.py | 64 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 178 | __all__ = ["ActivitySubprocess", "WatchedSubprocess", "supervise", "supervise_task"] | CODE |
| LOW | …/src/airflow/sdk/execution_time/callback_supervisor.py | 73 | __all__ = ["CallbackSubprocess", "supervise_callback"] | CODE |
| LOW | …rflow/sdk/execution_time/connection_test_supervisor.py | 35 | __all__ = ["supervise_connection_test"] | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 395 | def _set_variable(key: str, value: Any, description: str | None = None, serialize_json: bool = False) -> None: | CODE |
| LOW | …sdk/src/airflow/sdk/execution_time/secrets/__init__.py | 24 | __all__ = ["ExecutionAPISecretsBackend", "DEFAULT_SECRETS_SEARCH_PATH_WORKERS"] | CODE |
| LOW | …-sdk/src/airflow/sdk/execution_time/schema/__init__.py | 133 | __all__ = [ | CODE |
| LOW | …-sdk/src/airflow/sdk/execution_time/schema/migrator.py | 220 | __all__ = ["SchemaVersionMigrator", "get_schema_version_migrator"] | CODE |
| LOW | …-sdk/src/airflow/sdk/execution_time/sentry/__init__.py | 23 | __all__ = ["Sentry"] | CODE |
| LOW | task-sdk/src/airflow/sdk/api/client.py | 183 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/dag.py | 89 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/param.py | 35 | logger = logging.getLogger(__name__) | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/retry_policy.py | 39 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/deadline.py | 35 | logger = logging.getLogger(__name__) | CODE |
| LOW | …rc/airflow/sdk/definitions/_internal/contextmanager.py | 33 | __all__ = ["DagContext", "TaskGroupContext"] | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/_internal/types.py | 29 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/asset/metadata.py | 29 | __all__ = ["Metadata"] | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/asset/__init__.py | 49 | __all__ = [ | CODE |
| LOW | …sdk/src/airflow/sdk/definitions/decorators/__init__.py | 35 | __all__ = [ | CODE |
| LOW | …dk/src/airflow/sdk/definitions/decorators/condition.py | 36 | __all__ = ["run_if", "skip_if"] | CODE |
| LOW | …rs/neo4j/src/airflow/providers/neo4j/version_compat.py | 37 | __all__ = [ | CODE |
| LOW | providers/neo4j/src/airflow/providers/neo4j/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …/cohere/src/airflow/providers/cohere/version_compat.py | 33 | __all__ = [ | CODE |
| LOW | …viders/cohere/src/airflow/providers/cohere/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …rs/cohere/src/airflow/providers/cohere/hooks/cohere.py | 35 | logger = logging.getLogger(__name__) | CODE |
| LOW | …viders/ftp/src/airflow/providers/ftp/version_compat.py | 38 | __all__ = ["AIRFLOW_V_3_0_PLUS", "AIRFLOW_V_3_1_PLUS"] | CODE |
| LOW | providers/ftp/src/airflow/providers/ftp/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | providers/ftp/src/airflow/providers/ftp/hooks/ftp.py | 28 | logger = logging.getLogger(__name__) | CODE |
| LOW | …/presto/src/airflow/providers/presto/version_compat.py | 37 | __all__ = [ | CODE |
| LOW | …viders/presto/src/airflow/providers/presto/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …mill/src/airflow/providers/papermill/version_compat.py | 33 | __all__ = [ | CODE |
| LOW | …/papermill/src/airflow/providers/papermill/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …/docker/src/airflow/providers/docker/version_compat.py | 48 | __all__ = [ | CODE |
| LOW | …viders/docker/src/airflow/providers/docker/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …ders/imap/src/airflow/providers/imap/version_compat.py | 38 | __all__ = [ | CODE |
| LOW | providers/imap/src/airflow/providers/imap/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …iscord/src/airflow/providers/discord/version_compat.py | 39 | __all__ = [ | CODE |
| LOW | …ders/discord/src/airflow/providers/discord/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …ableau/src/airflow/providers/tableau/version_compat.py | 38 | __all__ = ["AIRFLOW_V_3_0_PLUS", "AIRFLOW_V_3_1_PLUS"] | CODE |
| LOW | …ders/tableau/src/airflow/providers/tableau/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …rs/amazon/tests/system/amazon/aws/example_sagemaker.py | 71 | logger = logging.getLogger(__name__) | CODE |
| LOW | …/amazon/src/airflow/providers/amazon/version_compat.py | 57 | __all__ = [ | CODE |
| LOW | …viders/amazon/src/airflow/providers/amazon/__init__.py | 30 | __all__ = ["__version__"] | CODE |
| LOW | …amazon/src/airflow/providers/amazon/aws/sensors/rds.py | 200 | __all__ = [ | CODE |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/rds.py | 980 | __all__ = [ | CODE |
| 366 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-ctl/src/airflowctl/ctl/commands/auth_command.py | 129 | # Check if directory exists | COMMENT |
| LOW | airflow-ctl/src/airflowctl/ctl/commands/auth_command.py | 201 | # Display results | COMMENT |
| LOW | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 1976 | # Assign task to Dag | COMMENT |
| LOW | task-sdk/dev/datamodel_code_formatter.py | 102 | # Check if the target is 'tasks' | COMMENT |
| LOW | task-sdk/src/airflow/sdk/configuration.py | 315 | # Check if the secrets_backend_list contains only 2 default backends. | COMMENT |
| LOW | task-sdk/src/airflow/sdk/configuration.py | 317 | # Check if we are loading the backends for worker too by checking if the default_backends is equal | COMMENT |
| LOW | task-sdk/src/airflow/sdk/bases/decorator.py | 223 | # Check if args conflict with names in kwargs. | COMMENT |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1128 | # Check if the subprocess has exited | COMMENT |
| LOW | task-sdk/src/airflow/sdk/definitions/taskgroup.py | 377 | # Check if the current TaskGroup is empty | COMMENT |
| LOW | …/airflow/sdk/definitions/_internal/abstractoperator.py | 240 | # Check if the operator has an explicit native rendering preference | COMMENT |
| LOW | task-sdk/src/airflow/sdk/serde/typing.py | 32 | # Check if it is not a dataclass to prevent detecting pydantic dataclasses as pydantic models | COMMENT |
| LOW | …ers/amazon/tests/unit/amazon/aws/operators/test_eks.py | 1141 | # Set status to None so define_container_state returns UNDEFINED (not terminal) | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py | 90 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py | 163 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py | 221 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py | 279 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py | 114 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py | 205 | # Check if object was created in s3 | COMMENT |
| LOW⚡ | providers/amazon/tests/system/amazon/aws/example_s3.py | 172 | # Check if a file exists | STRING |
| LOW⚡ | providers/amazon/tests/system/amazon/aws/example_s3.py | 181 | # Check if both files exist | STRING |
| LOW⚡ | providers/amazon/tests/system/amazon/aws/example_s3.py | 190 | # Check if a file exists | STRING |
| LOW⚡ | providers/amazon/tests/system/amazon/aws/example_s3.py | 200 | # Check if both files exist | STRING |
| LOW⚡ | providers/amazon/tests/system/amazon/aws/example_s3.py | 210 | # Check if a file exists and match a certain pattern defined in check_fn | STRING |
| LOW | providers/amazon/tests/system/amazon/aws/example_s3.py | 221 | # Check if a file exists and match a certain regular expression pattern | STRING |
| LOW | providers/amazon/tests/system/amazon/aws/example_s3.py | 232 | # Check if a file exists and match a certain pattern defined in check_fn | STRING |
| LOW | providers/amazon/tests/system/amazon/aws/example_s3.py | 242 | # Check if a file exists and match a certain regular expression pattern | STRING |
| LOW | providers/amazon/tests/system/amazon/aws/example_emr.py | 92 | # Set KeepJobFlowAliveWhenNoSteps to False to avoid the cluster from being torn down prematurely. | COMMENT |
| LOW | …amazon/src/airflow/providers/amazon/aws/sensors/ssm.py | 118 | # Check if we should tolerate this failure | COMMENT |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 347 | # Set wait_for_completion to False so that it waits for the status in the deferred task. | COMMENT |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 875 | # Set wait_for_completion to False so that it waits for the status in the deferred task. | COMMENT |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 1276 | # Set wait_for_completion to False so that it waits for the status in the deferred task. | COMMENT |
| LOW | …rflow/providers/amazon/aws/transfers/glacier_to_gcs.py | 99 | # Read the file content in chunks using StreamingBody | COMMENT |
| LOW | …low/providers/amazon/aws/executors/ecs/ecs_executor.py | 120 | # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the global | COMMENT |
| LOW | …providers/amazon/aws/executors/batch/batch_executor.py | 110 | # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the global | COMMENT |
| LOW | …ers/amazon/aws/executors/aws_lambda/lambda_executor.py | 89 | # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the global | COMMENT |
| LOW | …zon/src/airflow/providers/amazon/aws/hooks/base_aws.py | 581 | # Check if we can find an executor | COMMENT |
| LOW | …ers/teradata/tests/unit/teradata/operators/test_tpt.py | 292 | # Set hook to None | COMMENT |
| LOW | …ers/teradata/tests/unit/teradata/operators/test_tpt.py | 708 | # Set hooks to None | COMMENT |
| LOW⚡ | …rs/teradata/tests/unit/teradata/utils/test_tpt_util.py | 540 | # Check if permissions were set correctly | COMMENT |
| LOW | …adata/src/airflow/providers/teradata/operators/bteq.py | 43 | # Check if the parameter contains Jinja templating syntax | COMMENT |
| LOW⚡ | …data/src/airflow/providers/teradata/utils/bteq_util.py | 50 | # Check if zsh exists first | COMMENT |
| LOW | …adata/src/airflow/providers/teradata/utils/tpt_util.py | 77 | # Check if shred is available | COMMENT |
| LOW | …adata/src/airflow/providers/teradata/utils/tpt_util.py | 110 | # Check if shred is available on remote system (UNIX/Linux) | COMMENT |
| LOW | …dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py | 62 | # Check if ``account_id`` was not included in the function signature or, if it is, the value is not | COMMENT |
| LOW | …dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py | 843 | # Check if the job-run duration has exceeded the ``timeout`` configured. | COMMENT |
| LOW | …irflow/providers/edge3/plugins/edge_executor_plugin.py | 56 | # Check if EdgeExecutor is actually loaded | COMMENT |
| LOW | …src/airflow/providers/edge3/executors/edge_executor.py | 63 | # Check if self has the ExecutorConf set on the self.conf attribute with all required methods. | COMMENT |
| LOW | …src/airflow/providers/edge3/executors/edge_executor.py | 139 | # Check if job already exists with same dag_id, task_id, run_id, map_index, try_number | COMMENT |
| LOW | …e3/src/airflow/providers/edge3/worker_api/routes/ui.py | 290 | # Check if worker exists first | COMMENT |
| LOW | …/providers/google/common/utils/id_token_credentials.py | 151 | # Check if application default credentials exist. | COMMENT |
| LOW | …viders/google/cloud/sensors/vertex_ai/feature_store.py | 85 | # Check if the sync has completed by verifying end_time exists | COMMENT |
| LOW | …c/airflow/providers/google/cloud/operators/dataproc.py | 983 | # Check if cluster is not in ERROR state. | COMMENT |
| LOW | …airflow/providers/google/cloud/transfers/gcs_to_gcs.py | 295 | # Check if prefix contains wildcard | COMMENT |
| LOW | …e/src/airflow/providers/google/cloud/hooks/bigquery.py | 317 | # Check if tableReference is present and is valid | COMMENT |
| LOW | …e/src/airflow/providers/google/cloud/hooks/bigquery.py | 324 | # Check if value is already present if no use the provided one | COMMENT |
| LOW⚡ | …c/airflow/providers/google/cloud/openlineage/mixins.py | 403 | # Verify if the output table id from the parse result matches the BQ job output table | COMMENT |
| LOW⚡ | …c/airflow/providers/google/cloud/openlineage/mixins.py | 412 | # Verify if all columns from parse results are present in the output dataset schema | COMMENT |
| LOW⚡ | …c/airflow/providers/google/cloud/openlineage/mixins.py | 421 | # Verify if all datasets from parse results are present in bq job input datasets | COMMENT |
| LOW⚡ | …c/airflow/providers/google/cloud/openlineage/mixins.py | 425 | # Verify if all columns from parse results are present in their respective bq job input datasets | COMMENT |
| LOW | …rc/airflow/providers/google/cloud/openlineage/utils.py | 133 | # Check if the `InputField` class supports the `transformations` attribute (since OL client 1.17.1) | COMMENT |
| 161 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 3391 | secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e | CODE |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 3391 | secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e | CODE |
| LOW | providers/neo4j/tests/unit/neo4j/sensors/test_neo4j.py | 237 | cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name" | CODE |
| LOW | providers/neo4j/tests/unit/neo4j/sensors/test_neo4j.py | 252 | cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name" | CODE |
| LOW | providers/neo4j/tests/unit/neo4j/sensors/test_neo4j.py | 268 | cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name" | CODE |
| LOW | providers/docker/provider.yaml | 146 | extra: '{"reauth": false, "email": "Jane.Doe@example.org"}' | CODE |
| LOW | …cker/src/airflow/providers/docker/get_provider_info.py | 69 | "placeholders": {"extra": '{"reauth": false, "email": "Jane.Doe@example.org"}'}, | CODE |
| LOW | …rs/docker/src/airflow/providers/docker/hooks/docker.py | 229 | "email": "Jane.Doe@example.org", | CODE |
| LOW | …/tests/unit/amazon/aws/auth_manager/avp/test_facade.py | 92 | "dummy_id", | CODE |
| LOW | …/tests/unit/amazon/aws/auth_manager/avp/test_facade.py | 131 | "dummy_id", | CODE |
| LOW | …/teradata/tests/system/teradata/example_remote_bteq.py | 87 | INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT'); | CODE |
| LOW | providers/teradata/tests/system/teradata/script.sql | 26 | INSERT INTO {{params.TABLE_NAME}} VALUES (1, 'John Doe', 'IT'); | CODE |
| LOW | …oviders/teradata/tests/system/teradata/example_bteq.py | 87 | INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT'); | CODE |
| LOW | …ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py | 45 | "from": {"email": "foo@bar.com"}, | CODE |
| LOW⚡ | …ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py | 58 | "email": "foo@bar.com", | CODE |
| LOW⚡ | …ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py | 68 | @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com") | CODE |
| LOW | …ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py | 100 | @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com", SENDGRID_MAIL_SENDER="Foo") | CODE |
| LOW | …/edge3/tests/unit/edge3/worker_api/routes/test_logs.py | 62 | log_chunk_data="This is Lorem Ipsum log data", log_chunk_time=timezone.utcnow() | CODE |
| LOW | …/edge3/tests/unit/edge3/worker_api/routes/test_logs.py | 81 | assert "Lorem Ipsum" in logs[0].log_chunk_data | CODE |
| LOW | providers/trino/tests/unit/trino/hooks/test_trino.py | 580 | {"login": "user@example.com", "password": "p@ss:word", "host": "localhost", "schema": "hive"}, | CODE |
| LOW | …ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py | 73 | return_value="test-example@example.org" | CODE |
| LOW | …ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py | 98 | user="test-example@example.org", | CODE |
| LOW | …ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py | 145 | return_value="test-example@example.org" | CODE |
| LOW | …/system/google/cloud/dataflow/example_dataflow_yaml.py | 83 | "('John Doe', 900, 'USA'), " | CODE |
| LOW | …ts/unit/cncf/kubernetes/cli/test_kubernetes_command.py | 265 | pods.metadata._continue = "dummy-token" | CODE |
| LOW | …ts/unit/cncf/kubernetes/cli/test_kubernetes_command.py | 280 | _continue="dummy-token", | CODE |
| LOW | …ers/pgvector/tests/system/pgvector/example_pgvector.py | 62 | f"VALUES ('John Doe', 123, '[1.0, 2.0, 3.0]')", | CODE |
| LOW | …ector/tests/system/pgvector/example_pgvector_openai.py | 75 | f"VALUES ('John Doe', '123' ,'{embedd_query.output}')", | CODE |
| LOW | …cks/tests/unit/databricks/operators/test_databricks.py | 173 | "name": "John Doe", | CODE |
| LOW | providers/fab/tests/unit/fab/auth_manager/test_utils.py | 54 | email=email or f"{username}@example.org", | CODE |
| LOW⚡ | …unit/fab/auth_manager/api_fastapi/routes/test_login.py | 33 | dummy_token = LoginResponse(access_token="DUMMY_TOKEN") | CODE |
| LOW⚡ | …unit/fab/auth_manager/api_fastapi/routes/test_login.py | 38 | mock_fab_auth_manager_login.create_token.return_value = self.dummy_token | CODE |
| LOW⚡ | …unit/fab/auth_manager/api_fastapi/routes/test_login.py | 46 | assert response.json()["access_token"] == self.dummy_token.access_token | CODE |
| LOW | …unit/fab/auth_manager/api_fastapi/routes/test_login.py | 59 | assert response.json()["access_token"] == self.dummy_token.access_token | CODE |
| LOW⚡ | …it/fab/auth_manager/api_fastapi/services/test_login.py | 46 | self.dummy_token = "DUMMY_TOKEN" | CODE |
| LOW⚡ | …it/fab/auth_manager/api_fastapi/services/test_login.py | 50 | auth_manager.generate_jwt.return_value = self.dummy_token | CODE |
| LOW⚡ | …it/fab/auth_manager/api_fastapi/services/test_login.py | 58 | assert result.access_token == self.dummy_token | CODE |
| LOW | …viders/fab/src/airflow/providers/fab/cli/definition.py | 164 | " --email admin@example.org" | CODE |
| LOW⚡ | …snowflake/tests/unit/snowflake/hooks/test_snowflake.py | 1553 | assert token == "dummy_token" | CODE |
| LOW⚡ | …snowflake/tests/unit/snowflake/hooks/test_snowflake.py | 1568 | json=lambda: {"access_token": "dummy_token", "expires_in": 600}, | CODE |
| LOW | …snowflake/tests/unit/snowflake/hooks/test_snowflake.py | 1531 | json=lambda: {"access_token": "dummy_token", "expires_in": 600}, | CODE |
| LOW | …snowflake/tests/unit/snowflake/hooks/test_snowflake.py | 1585 | assert token == "dummy_token" | CODE |
| LOW | providers/jdbc/tests/unit/jdbc/hooks/test_jdbc.py | 283 | "placeholder": "?", | CODE |
| LOW | …mmon/ai/tests/unit/common/ai/operators/test_llm_sql.py | 680 | prompt="placeholder", | CODE |
| LOW | …common/ai/tests/unit/common/ai/operators/test_agent.py | 648 | prompt="placeholder", | CODE |
| LOW | …s/common/ai/tests/unit/common/ai/operators/test_llm.py | 398 | prompt="placeholder", | CODE |
| LOW | …/common/sql/datafusion/test_object_storage_provider.py | 38 | credentials={"access_key_id": "fake_key", "secret_access_key": "fake_secret"}, | CODE |
| LOW | …/common/sql/datafusion/test_object_storage_provider.py | 44 | access_key_id="fake_key", secret_access_key="fake_secret", bucket_name="demo-data" | CODE |
| LOW⚡ | …ers/common/sql/tests/unit/common/sql/hooks/test_sql.py | 254 | dbapi_hook = mock_db_hook(DbApiHook, conn_params={"extra": {"placeholder": "?"}}) | CODE |
| LOW⚡ | …ers/common/sql/tests/unit/common/sql/hooks/test_sql.py | 260 | dbapi_hook = mock_db_hook(DbApiHook, conn_params={"extra": {"placeholder": "!"}}) | CODE |
| LOW⚡ | …s/common/sql/tests/unit/common/sql/hooks/test_dbapi.py | 504 | extra=json.dumps({"placeholder": "?"}), | CODE |
| LOW⚡ | …s/common/sql/tests/unit/common/sql/hooks/test_dbapi.py | 521 | extra=json.dumps({"placeholder": "!"}), | CODE |
| LOW | …mmon/sql/src/airflow/providers/common/sql/hooks/sql.py | 201 | placeholder = self.connection_extra.get("placeholder") | CODE |
| LOW | providers/odbc/src/airflow/providers/odbc/hooks/odbc.py | 153 | extra_exclude = {"driver", "dsn", "connect_kwargs", "sqlalchemy_scheme", "placeholder"} | CODE |
| LOW | …/tests/unit/keycloak/auth_manager/cli/test_commands.py | 70 | {"id": "dummy-id", "clientId": "dummy-client"}, | CODE |
| LOW | …/tests/unit/keycloak/auth_manager/cli/test_commands.py | 100 | {"id": "dummy-id", "clientId": "dummy-client"}, | CODE |
| LOW | …/tests/unit/keycloak/auth_manager/cli/test_commands.py | 129 | {"id": "dummy-id", "clientId": "dummy-client"}, | CODE |
| LOW | …/tests/unit/keycloak/auth_manager/cli/test_commands.py | 187 | {"id": "dummy-id", "clientId": "dummy-client"}, | CODE |
| LOW | …/tests/unit/keycloak/auth_manager/cli/test_commands.py | 237 | {"id": "dummy-id", "clientId": "dummy-client"}, | CODE |
| LOW | …/tests/unit/keycloak/auth_manager/cli/test_commands.py | 346 | {"id": "dummy-id", "clientId": "dummy-client"}, | CODE |
| 196 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-ctl/tests/conftest.py | 65 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 391 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 400 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 409 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 418 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 429 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 440 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 506 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 515 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 524 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 533 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 542 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 673 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 682 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 691 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 706 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 759 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 768 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 783 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1034 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1043 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1052 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1061 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1070 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1079 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1088 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1097 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1108 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1117 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1126 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1196 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1206 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1440 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1449 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1458 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1467 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1476 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1543 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1552 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1561 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1570 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1579 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1588 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 354 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 363 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 377 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 482 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 495 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 570 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 586 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 610 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 722 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 746 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 811 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 830 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1137 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1148 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1219 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1236 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1294 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| 146 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 679 | # Step 1: Simulate CLI args being parsed (logical_date=None) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 704 | # Step 3: Create the Pydantic model (what happens in the actual code) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 707 | # Step 4: Verify logical_date was set to now | COMMENT |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 693 | # Step 2: Apply the defaulting logic (from cli_config.py lines 622-630) | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 667 | # Step 1: create the dag run span and capture its carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 674 | # Step 2: derive the parent task span carrier (child of dag run), as the scheduler does. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 684 | # Step 3: build StartupDetails with ti.context_carrier = ti_carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 703 | # Step 4: emit the worker span (task runner side). | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 709 | # Step 5: emit the parent task span (API server side, as happens on task completion). | COMMENT |
| LOW | task-sdk/src/airflow/sdk/bases/decorator.py | 133 | # We need to check if we are in the context of TaskGroup as the task_id may | COMMENT |
| LOW | …google/cloud/compute/example_compute_recreate_drift.py | 91 | # Step 1: Create with machine type A. | COMMENT |
| LOW | …google/cloud/compute/example_compute_recreate_drift.py | 102 | # Step 2: Re-run with different machine type and recreate recreate_if_machine_type_different=True. | COMMENT |
| LOW⚡ | …google/cloud/compute/example_compute_recreate_drift.py | 114 | # Step 3: Validate new machine type. | COMMENT |
| LOW⚡ | …google/cloud/compute/example_compute_recreate_drift.py | 120 | # Step 4: Cleanup. | COMMENT |
| LOW | …iders/cncf/kubernetes/executors/kubernetes_executor.py | 691 | # therefore, we need to check if the TIs are already adopted by the first attempt and remove them. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 164 | # Step 1: Decompose the high-level question into sub-questions, | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 193 | # Step 2: Generate SQL for each sub-question in parallel. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 207 | # Step 3: Wrap each SQL string into a single-element list. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 218 | # Step 4: Execute each SQL against the survey CSV via DataFusion. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 229 | # Step 5: Collect all four JSON results and label them by dimension. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 248 | # Step 6: Synthesize the four labeled result sets into a narrative. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 267 | # Step 7: Human reviews the synthesized narrative before the DAG ends. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 408 | # Step 1: Analyst submits the comparison question via HITL. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 443 | # Step 2: LLM decomposes the question into company-specific | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 473 | # Step 3: Map sub-questions to retrieval kwargs. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 490 | # Step 4: Retrieve relevant chunks for each sub-question. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 526 | # Step 5: Collect all retrieval results into a single context. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 541 | # Step 6: Synthesize a structured comparison report. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 567 | # Step 7: Format the structured report into readable text for the | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 599 | # Step 8: Analyst reviews the report before it reaches the | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 420 | # Step 1: Build the AIP list from the registry, using Confluence page | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 454 | # Step 2: Fetch the repo file tree from GitHub once, shared across | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 491 | # Step 3: Gather evidence from Confluence, GitHub, and the file tree. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 601 | # Step 4: Format the gathered evidence into an LLM analysis prompt. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 627 | # Step 5: Analyze each AIP with a structured LLM call. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 643 | # Step 6: Collect all per-AIP analyses into a combined context. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 660 | # Step 7: Format the structured analyses as readable markdown. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 711 | # Step 8: Synthesize a cross-AIP progress report. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 737 | # Step 9: AI-powered hallucination validation. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 769 | # Step 10: Apply validation corrections deterministically. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 849 | # Step 11: Build the review body for the human reviewer, showing | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 888 | # Step 12: A maintainer reviews the corrected report. The DAG | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 365 | # Step 1: Analyst submits the comparison question via HITL. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 400 | # Step 2: LLM decomposes the question into company-specific | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 430 | # Step 3: Map sub-questions to LlamaIndexRetrievalOperator kwargs. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 446 | # Step 4: Retrieve relevant chunks for each sub-question. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 460 | # Step 5: Collect all retrieval results into a single context. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 478 | # Step 6: Synthesize a structured comparison report. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 504 | # Step 7: Format the structured report into readable text for the | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 536 | # Step 8: Analyst reviews the report before it reaches the | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 317 | # Step 4: SQL generation -- LLM translates the fixed question. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 329 | # Step 5: SQL execution via Apache DataFusion. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 339 | # Step 6: Extract data rows from the JSON result. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 351 | # Step 7: Send result via email if SMTP is configured, otherwise log. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 175 | # Step 1: Prompt confirmation -- review or edit the question. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 191 | # Step 2: SQL generation -- LLM translates the confirmed question. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 202 | # Step 3: SQL execution via Apache DataFusion. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 212 | # Step 4: Extract data rows from the JSON result. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 225 | # Step 5: Result confirmation -- approve or reject the query result. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 271 | # Step 1: Download the survey CSV from the Airflow website. | STRING |
| 20 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 679 | # Step 1: Simulate CLI args being parsed (logical_date=None) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 704 | # Step 3: Create the Pydantic model (what happens in the actual code) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 707 | # Step 4: Verify logical_date was set to now | COMMENT |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 693 | # Step 2: Apply the defaulting logic (from cli_config.py lines 622-630) | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 667 | # Step 1: create the dag run span and capture its carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 674 | # Step 2: derive the parent task span carrier (child of dag run), as the scheduler does. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 684 | # Step 3: build StartupDetails with ti.context_carrier = ti_carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 703 | # Step 4: emit the worker span (task runner side). | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 709 | # Step 5: emit the parent task span (API server side, as happens on task completion). | COMMENT |
| LOW | …google/cloud/compute/example_compute_recreate_drift.py | 91 | # Step 1: Create with machine type A. | COMMENT |
| LOW | …google/cloud/compute/example_compute_recreate_drift.py | 102 | # Step 2: Re-run with different machine type and recreate recreate_if_machine_type_different=True. | COMMENT |
| LOW⚡ | …google/cloud/compute/example_compute_recreate_drift.py | 114 | # Step 3: Validate new machine type. | COMMENT |
| LOW⚡ | …google/cloud/compute/example_compute_recreate_drift.py | 120 | # Step 4: Cleanup. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 164 | # Step 1: Decompose the high-level question into sub-questions, | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 193 | # Step 2: Generate SQL for each sub-question in parallel. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 207 | # Step 3: Wrap each SQL string into a single-element list. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 218 | # Step 4: Execute each SQL against the survey CSV via DataFusion. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 229 | # Step 5: Collect all four JSON results and label them by dimension. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 248 | # Step 6: Synthesize the four labeled result sets into a narrative. | COMMENT |
| LOW⚡ | …s/common/ai/example_dags/example_llm_survey_agentic.py | 267 | # Step 7: Human reviews the synthesized narrative before the DAG ends. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 408 | # Step 1: Analyst submits the comparison question via HITL. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 443 | # Step 2: LLM decomposes the question into company-specific | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 473 | # Step 3: Map sub-questions to retrieval kwargs. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 490 | # Step 4: Retrieve relevant chunks for each sub-question. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 526 | # Step 5: Collect all retrieval results into a single context. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 541 | # Step 6: Synthesize a structured comparison report. | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 567 | # Step 7: Format the structured report into readable text for the | COMMENT |
| LOW⚡ | …viders/common/ai/example_dags/example_langchain_10k.py | 599 | # Step 8: Analyst reviews the report before it reaches the | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 420 | # Step 1: Build the AIP list from the registry, using Confluence page | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 454 | # Step 2: Fetch the repo file tree from GitHub once, shared across | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 491 | # Step 3: Gather evidence from Confluence, GitHub, and the file tree. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 601 | # Step 4: Format the gathered evidence into an LLM analysis prompt. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 627 | # Step 5: Analyze each AIP with a structured LLM call. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 643 | # Step 6: Collect all per-AIP analyses into a combined context. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 660 | # Step 7: Format the structured analyses as readable markdown. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 711 | # Step 8: Synthesize a cross-AIP progress report. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 737 | # Step 9: AI-powered hallucination validation. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 769 | # Step 10: Apply validation corrections deterministically. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 849 | # Step 11: Build the review body for the human reviewer, showing | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 888 | # Step 12: A maintainer reviews the corrected report. The DAG | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 365 | # Step 1: Analyst submits the comparison question via HITL. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 400 | # Step 2: LLM decomposes the question into company-specific | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 430 | # Step 3: Map sub-questions to LlamaIndexRetrievalOperator kwargs. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 446 | # Step 4: Retrieve relevant chunks for each sub-question. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 460 | # Step 5: Collect all retrieval results into a single context. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 478 | # Step 6: Synthesize a structured comparison report. | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 504 | # Step 7: Format the structured report into readable text for the | COMMENT |
| LOW⚡ | …iders/common/ai/example_dags/example_llamaindex_10k.py | 536 | # Step 8: Analyst reviews the report before it reaches the | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 317 | # Step 4: SQL generation -- LLM translates the fixed question. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 329 | # Step 5: SQL execution via Apache DataFusion. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 339 | # Step 6: Extract data rows from the JSON result. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 351 | # Step 7: Send result via email if SMTP is configured, otherwise log. | COMMENT |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 175 | # Step 1: Prompt confirmation -- review or edit the question. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 191 | # Step 2: SQL generation -- LLM translates the confirmed question. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 202 | # Step 3: SQL execution via Apache DataFusion. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 212 | # Step 4: Extract data rows from the JSON result. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 225 | # Step 5: Result confirmation -- approve or reject the query result. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 271 | # Step 1: Download the survey CSV from the Airflow website. | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 283 | # Step 2: Write the downloaded CSV to disk and generate a reference | STRING |
| LOW⚡ | …/common/ai/example_dags/example_llm_survey_analysis.py | 302 | # Step 3: Validate the downloaded CSV schema against the reference. | STRING |
| 18 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | airflow-e2e-tests/docker/openlineage.yml | 27 | # These DAGs are the only ones the harness drives; keep the stock example DAGs out of the way. | COMMENT |
| MEDIUM | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 603 | # so it must not also load the stock e2e dags — the harness triggers every dag it finds. | COMMENT |
| MEDIUM | …ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py | 45 | # The marker after which everything is Airflow's in-process test harness (pytest-only). | COMMENT |
| MEDIUM | task-sdk/tests/task_sdk/bases/test_operator.py | 83 | # Essentially similar to airflow.models.baseoperator.BaseOperator | COMMENT |
| LOW | task-sdk/src/airflow/sdk/execution_time/comms.py | 228 | # `__class_getitem__`, but that's a lot of code the one subclass we've got currently. So we'll just use a | COMMENT |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 2217 | # and it doesn't contain a new line character, `.readline()` will just return the chunk as is. | COMMENT |
| LOW | …rs/amazon/tests/unit/amazon/aws/hooks/test_datasync.py | 43 | # mock_get_conn. We then override it to just return the locally created self.client instead of | COMMENT |
| LOW | …/amazon/src/airflow/providers/amazon/aws/sensors/s3.py | 182 | # Otherwise, just pass the files | COMMENT |
| LOW | …irflow/providers/amazon/aws/operators/redshift_data.py | 242 | # case, pull each of the sub-statement ID's, and grab the results. Otherwise, just use statement_id | COMMENT |
| MEDIUM | …viders/edge3/src/airflow/providers/edge3/cli/worker.py | 547 | # Technically safer and more robust, but with more overhead | COMMENT |
| MEDIUM | …irflow/providers/google/cloud/utils/field_validator.py | 350 | # Certainly down from here the field is present (value is not None) | COMMENT |
| LOW | …w/providers/google/cloud/utils/credentials_provider.py | 498 | # if it's already a dict, just return it | COMMENT |
| MEDIUM | …rc/airflow/providers/google/cloud/hooks/compute_ssh.py | 42 | # TODO:(potiuk) We should add test harness detecting such cases shortly | COMMENT |
| LOW | …e/src/airflow/providers/snowflake/utils/openlineage.py | 107 | # else - its new hostname, just return it | COMMENT |
| MEDIUM | …/ai/src/airflow/providers/common/ai/operators/agent.py | 105 | # Only report "extra not installed" when pydantic-ai-harness itself is | COMMENT |
| LOW | …lineage/tests/unit/openlineage/extractors/test_base.py | 454 | # just return empty OperatorLineage | COMMENT |
| MEDIUM | …ders/openlineage/tests/system/openlineage/constants.py | 25 | # Overridable via env var — the e2e harness runs every DAG in the same deployment and wants a | COMMENT |
| LOW | …lineage/src/airflow/providers/openlineage/utils/sql.py | 203 | # Don't iterate over tables hierarchy, just pass it to query single information schema table | COMMENT |
| LOW | …e/src/airflow/providers/salesforce/hooks/salesforce.py | 252 | # just return the original column untouched | COMMENT |
| MEDIUM | chart/values.yaml | 31 | # For now this is an opt-in switch for backwards compatibility to leverage the standard naming convention | COMMENT |
| MEDIUM | chart/values.yaml | 316 | # Specify executors in a prioritized list to leverage multiple execution environments as needed: | COMMENT |
| MEDIUM | chart/files/statsd-mappings.yml | 21 | # instead utilize `statsd.extraMappings` or `statsd.overrideMappings` in your environment, | COMMENT |
| LOW | …nfiguration/src/airflow_shared/configuration/parser.py | 1423 | # have these types is with `fallback=` was specified. So just return it. | COMMENT |
| LOW | …ared/logging/src/airflow_shared/logging/_noncaching.py | 36 | # we should simply return the wrapper retrieved by FileHandler's open method | COMMENT |
| LOW⚡ | airflow-core/tests/unit/cli/test_hot_reload.py | 63 | # Should just call the callback directly | COMMENT |
| LOW | …/src/airflow/api_fastapi/execution_api/routes/xcoms.py | 359 | # TODO: once we have JWT tokens, then remove dag_id/run_id/task_id from the URL and just use the info in | COMMENT |
| MEDIUM⚡ | …c/airflow/config_templates/default_webserver_config.py | 111 | # in order to fully utilize the theme. (or use that property in conjunction with theme) | COMMENT |
| MEDIUM⚡ | …c/airflow/config_templates/default_webserver_config.py | 111 | # in order to fully utilize the theme. (or use that property in conjunction with theme) | COMMENT |
| LOW | airflow-core/src/airflow/timetables/trigger.py | 289 | # values, so we can just use the first to represent them. | COMMENT |
| MEDIUM⚡ | airflow-core/src/airflow/triggers/base.py | 485 | """Yield this event in order to end the task successfully.""" | STRING |
| MEDIUM⚡ | airflow-core/src/airflow/triggers/base.py | 491 | """Yield this event in order to end the task with failure.""" | STRING |
| MEDIUM⚡ | airflow-core/src/airflow/triggers/base.py | 497 | """Yield this event in order to end the task with status 'skipped'.""" | STRING |
| LOW | airflow-core/src/airflow/serialization/encoders.py | 413 | # values, so we can just use the first to represent them. | COMMENT |
| LOW | airflow-core/src/airflow/utils/db.py | 1490 | # Older version before we added that function, it only has a single migration so we can just create the tables | COMMENT |
| LOW | airflow-core/src/airflow/utils/dot_renderer.py | 241 | # (we can just use the maybe-None label variable directly) | COMMENT |
| LOW | airflow-core/src/airflow/utils/sqlalchemy.py | 318 | # below is the only line we change, and we just add default=None for getattr | COMMENT |
| LOW | …core/src/airflow/utils/log/non_caching_file_handler.py | 31 | # we should simply return the wrapper retrieved by FileHandler's open method | COMMENT |
| LOW | airflow-core/src/airflow/cli/commands/db_command.py | 66 | # Exact match found, we can just return it | COMMENT |
| LOW | …flow-core/src/airflow/dag_processing/importers/base.py | 238 | # If it's a file, just return it if we can handle it | COMMENT |
| LOW | dev/breeze/src/airflow_breeze/params/shell_params.py | 518 | # Socket is something different (TCP?) just pass it through as DOCKER_HOST variable | COMMENT |
| MEDIUM | …airflow_breeze/commands/release_management_commands.py | 2232 | """Cleans up the old airflow providers artifacts in order to maintain | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | clients/python/test_python_client.py | 53 | # auth manager for instance AwsAuthManagerUser or SimpleAuthManager make sure to generate the token with | COMMENT |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 113 | # If you are updating here don't forget to update the airflow-ctl-tests | COMMENT |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 113 | # If you are updating here don't forget to update the airflow-ctl-tests | COMMENT |
| LOW | …mazon/tests/system/amazon/aws/example_mwaa_airflow2.py | 58 | # If creating the environment using the AWS console, make sure to have a VPC with | COMMENT |
| LOW | …oviders/amazon/tests/system/amazon/aws/example_mwaa.py | 59 | # If creating the environment using the AWS console, make sure to have a VPC with | COMMENT |
| MEDIUM | …adata/src/airflow/providers/teradata/hooks/teradata.py | 84 | # Optionally, you can replace the original value in the query_band_text | COMMENT |
| MEDIUM | …stem/google/cloud/dataplex/example_dataplex_catalog.py | 80 | "description": "A simple AspectType for demonstration purposes.", | CODE |
| MEDIUM | …ers/pgvector/tests/system/pgvector/example_pgvector.py | 22 | # If you only need Airflow 3+, you can use: from airflow.sdk import dag, task | COMMENT |
| MEDIUM | …ector/tests/system/pgvector/example_pgvector_openai.py | 22 | # If you only need Airflow 3+, you can use: from airflow.sdk import dag, task, teardown | COMMENT |
| MEDIUM | …ineage/tests/unit/openlineage/plugins/test_listener.py | 395 | # Now you can use listener and task_instance in your tests to simulate their interaction. | STRING |
| MEDIUM | …ineage/tests/unit/openlineage/plugins/test_listener.py | 1270 | # Now you can use listener and task_instance in your tests to simulate their interaction. | STRING |
| MEDIUM | …airbyte/src/airflow/providers/airbyte/hooks/airbyte.py | 61 | # Intentionally left the password out, you can modify the log to print it out if you are doing testing. | COMMENT |
| MEDIUM | …irflow/providers/apache/tinkerpop/operators/gremlin.py | 46 | # If you prefer, you can add an alias run_query = run in your hook. | COMMENT |
| MEDIUM | providers/openai/tests/system/openai/example_openai.py | 22 | # If you only need Airflow 3+, you can use: from airflow.sdk import dag, task | COMMENT |
| MEDIUM | chart/values.yaml | 469 | # or, you can use a different database like: | COMMENT |
| MEDIUM | chart/values.yaml | 569 | # This is an example config showing how you can use templating and how "example" config | COMMENT |
| LOW⚡ | …art/tests/helm_tests/airflow_aux/test_chart_quality.py | 36 | # we don't forget to update the schema if we add a new property | COMMENT |
| LOW⚡ | …art/tests/helm_tests/airflow_aux/test_chart_quality.py | 36 | # we don't forget to update the schema if we add a new property | COMMENT |
| MEDIUM | …low-core/docs/howto/docker-compose/docker-compose.yaml | 45 | # Feel free to modify this file to suit your needs. | COMMENT |
| MEDIUM | …low-core/docs/howto/docker-compose/docker-compose.yaml | 49 | # In order to add custom dependencies or upgrade provider distributions you can use your extended image. | COMMENT |
| MEDIUM⚡ | …c/airflow/config_templates/default_webserver_config.py | 108 | # that you can use for Apache Airflow. | COMMENT |
| LOW⚡ | …c/airflow/config_templates/default_webserver_config.py | 110 | # Please make sure to remove "navbar_color" configuration from airflow.cfg | COMMENT |
| MEDIUM | …src/airflow/example_dags/example_params_ui_tutorial.py | 52 | # Therefore you can add the "section" attribute. | COMMENT |
| MEDIUM | …src/airflow/example_dags/example_params_ui_tutorial.py | 54 | # Note if you can add any Markdown formatting to the description, you need to use the description_md | COMMENT |
| MEDIUM | …src/airflow/example_dags/example_params_ui_tutorial.py | 69 | # If you want to have a selection list box then you can use the enum feature of JSON schema | COMMENT |
| MEDIUM | …src/airflow/example_dags/example_params_ui_tutorial.py | 168 | # then you can use the examples feature of JSON schema | COMMENT |
| MEDIUM | …src/airflow/example_dags/example_params_ui_tutorial.py | 288 | # then you can use the JSON schema option of passing constant values. These parameters | COMMENT |
| LOW | scripts/ci/prek/check_integrations_list.py | 201 | "[yellow]Regenerating documentation table. Don't forget to review and commit possible changes.[/]" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …radata/src/airflow/providers/teradata/operators/tpt.py | 176 | Normalize error_list parameter to a list of integers. Args: error_list: An integer, list o | STRING |
| HIGH | …radata/src/airflow/providers/teradata/operators/tpt.py | 577 | Handle execution using a local job variable file. Args: file_path: Path to the local job v | STRING |
| HIGH | …s/teradata/src/airflow/providers/teradata/hooks/tpt.py | 86 | Execute a DDL statement using TPT. Args: tpt_script: TPT script content as string or list | STRING |
| HIGH | …s/teradata/src/airflow/providers/teradata/hooks/tpt.py | 247 | Execute a tdload operation using the tdload command-line utility. Args: remote_working_dir | STRING |
| HIGH | …rc/airflow/providers/google/cloud/openlineage/utils.py | 63 | Merge multiple column lineage facets into a single consolidated facet. Specifically, it aggregates input field | STRING |
| HIGH | …rc/airflow/providers/google/cloud/openlineage/utils.py | 163 | Extract and process the dataset name from a given path. Args: path: The path to process e.g. of a gcs | STRING |
| HIGH | …rc/airflow/providers/google/cloud/openlineage/utils.py | 276 | Get column lineage facet for identity transformations. This function generates a simple column lineage facet, | STRING |
| HIGH | …rc/airflow/providers/google/cloud/openlineage/utils.py | 418 | Replace the properties of a specific job type in a Dataproc job definition. Args: job: The original Da | STRING |
| HIGH | …ndard/src/airflow/providers/standard/operators/hitl.py | 300 | Generate a URL link to the "required actions" page for a specific task instance. This URL includes que | STRING |
| HIGH | …e/tests/system/openlineage/expected_events/__init__.py | 31 | Retrieve the file path to the OpenLineage expected events JSON file for a given DAG ID, taking into account the | STRING |
| HIGH | …c/airflow/api_fastapi/core_api/services/ui/calendar.py | 291 | Get database-specific time truncation expression for SQLAlchemy. We want to return always timestamp fo | STRING |
| HIGH | …sdk-integration-tests/tests/task_sdk_tests/conftest.py | 436 | Utility to set up a DAG run and create an SDK client. This function handles the common pattern of: 1. Gett | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | pyproject.toml | 725 | # FastAPI dependency injection uses function calls in argument defaults intentionally. | COMMENT |
| MEDIUM | pyproject.toml | 801 | # Annotated is central for FastAPI dependency injection, skipping rules for FastAPI folders. | COMMENT |
| MEDIUM | .apache-magpie-overrides/README.md | 30 | [`docs/setup/agentic-overrides.md`](https://github.com/apache/magpie/blob/main/docs/setup/agentic-overrides.md) | CODE |
| MEDIUM | …viders/amazon/tests/system/amazon/aws/utils/bedrock.py | 49 | # Haiku has some version dependency issues: RAG only supports 3.5 but batch only supports 4.5 | COMMENT |
| MEDIUM | …/unit/common/ai/operators/test_llamaindex_retrieval.py | 101 | # The retrieval-time embedding model is passed directly (no Settings mutation). | COMMENT |
| MEDIUM | …common/ai/tests/unit/common/ai/hooks/test_langchain.py | 96 | # extra placeholder shows both chat and embedding model keys | COMMENT |
| MEDIUM⚡ | …common/ai/example_dags/example_langchain_tool_agent.py | 217 | # re-initialising the embedding model on every call would be wasteful. | COMMENT |
| MEDIUM⚡ | …iders/common/ai/example_dags/example_llamaindex_rag.py | 41 | # 1. Full RAG pipeline: load -> embed -> retrieve -> answer | COMMENT |
| MEDIUM⚡ | …iders/common/ai/example_dags/example_llamaindex_rag.py | 192 | # 3. Multi-source RAG: combine CSV product data with text documentation | COMMENT |
| MEDIUM⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 737 | # Step 9: AI-powered hallucination validation. | COMMENT |
| MEDIUM | …irflow/providers/common/ai/example_dags/example_llm.py | 136 | # tokens, or 1_000 output tokens. Useful for guardrails on shared | COMMENT |
| MEDIUM | .agents/skills/magpie-setup/overrides.md | 4 | # overrides — manage agentic overrides for framework skills | COMMENT |
| MEDIUM | .agents/skills/magpie-setup/overrides.md | 71 | ## Override file scaffold | COMMENT |
| MEDIUM | .agents/skills/magpie-setup/adopt.md | 703 | [`docs/setup/agentic-overrides.md`](https://github.com/apache/magpie/blob/main/docs/setup/agentic-overrides.md) | CODE |
| MEDIUM | …flow-core/src/airflow/api_fastapi/execution_api/app.py | 404 | # Set up dag_bag in app state for dependency injection | COMMENT |
| MEDIUM | airflow-core/src/airflow/models/trigger.py | 451 | # It prioritizes callbacks, then DAGs over event driven scheduling which is fair | COMMENT |
| MEDIUM | …c/adr/0017-use-uvx-to-run-breeze-from-local-sources.md | 91 | # so each worktree (e.g. parallel agentic runs) gets its own ephemerally-installed | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 476 | CODE | |
| MEDIUM | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 489 | CODE | |
| MEDIUM | …es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 1422 | CODE | |
| MEDIUM | …es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 1616 | CODE | |
| MEDIUM | …ers/standard/tests/unit/standard/triggers/test_file.py | 260 | CODE | |
| MEDIUM | airflow-core/tests/unit/triggers/test_shared_stream.py | 192 | CODE | |
| MEDIUM | airflow-core/tests/unit/triggers/test_shared_stream.py | 2552 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 1228 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 622 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 693 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 709 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 735 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 908 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 925 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 1266 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 1313 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_dagrun.py | 3934 | CODE | |
| MEDIUM | airflow-core/src/airflow/triggers/base.py | 188 | CODE | |
| MEDIUM | airflow-core/src/airflow/triggers/base.py | 382 | CODE | |
| MEDIUM | airflow-core/src/airflow/triggers/base.py | 425 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …rc/airflow/providers/edge3/example_dags/win_notepad.py | 72 | "This is a text as proposal generated by Airflow DAG. Change it and save and it will get to XCom.", | CODE |
| HIGH | …cncf/kubernetes/executors/kubernetes_executor_utils.py | 790 | :param kube_config: The KubeConfig class generated by airflow that contains all kube metadata | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | providers/informatica/dev/docker-compose.yml | 20 | # Usage: | COMMENT |
| LOW | java-sdk/scripts/ci/verify-source-release.sh | 22 | # Usage: | COMMENT |
| LOW | java-sdk/scripts/ci/smoke-test-staged-binaries.sh | 25 | # Usage: | COMMENT |
| LOW | dev/prune_old_dirs.py | 22 | # Usage: | COMMENT |
| LOW | dev/sync_fork.sh | 28 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …src/airflow/example_dags/example_params_ui_tutorial.py | 128 | # In this example we have no default value | COMMENT |