Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
This report summarizes scanner evidence for apache/airflow, a Python project with 47,139 GitHub stars. SynthScan examined 2,379,215 lines of code across 11326 source files, recording 53062 pattern matches distributed across 26 syntactic categories. The legacy adjusted pattern signal is 24.6 (Elevated pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 42161 finding(s).
Are imports declared and package/API names verified? 7718 finding(s).
Are wrappers, guards, and repeated structures necessary? 34112 finding(s).
Which changes need focused human review? 53062 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 53062 distinct pattern matches across 26 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. 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 configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | clients/python/README.md | 297 | def get_airflow_client_access_token( | CODE |
| LOW | …/java-test-bundle/src/resources/dags/java_test_dags.py | 25 | def missing_no_arg_constructor(): ... | CODE |
| LOW⚡ | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 722 | def _build_ts_sdk_example_bundle(*, native=False): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 100 | def _copy_elasticsearch_files(tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 126 | def _setup_elasticsearch_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 141 | def _setup_opensearch_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 172 | def _write_providers_mount_override(tmp_dir: Path, providers: list[str]) -> list[str]: | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 200 | def _setup_event_driven_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 249 | def _setup_xcom_object_storage_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 390 | def _setup_java_sdk_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 624 | def _setup_go_sdk_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 703 | def _setup_openlineage_integration(dot_env_file, tmp_dir, compose_file_names): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 768 | def _setup_ts_sdk_integration(dot_env_file, tmp_dir): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 815 | def spin_up_airflow_environment(tmp_path_factory: pytest.TempPathFactory): | CODE |
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 931 | 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 | 47 | def create_request_session_with_retries(status_forcelist: list[int]): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 154 | def _trigger_and_wait_for_dag(dag_id: str, timeout: int) -> _CompletedRun: | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 211 | def test_java_tasks_execute_successfully(self, annotation_example_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 222 | def test_transform_xcom_is_numeric_timestamp(self, annotation_example_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 232 | def test_report_binds_keyword_arguments_by_folded_name(self, annotation_example_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 245 | def test_concurrent_client_calls_succeed(self, annotation_example_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 256 | def test_load_retried_then_succeeded(self, annotation_example_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 276 | def test_application_logs_preserve_their_level(self, annotation_example_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 330 | def test_uninstantiable_task_fails_with_actionable_error(self, task_id: str, expected_task_class: str): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 373 | def test_variable_written_by_java_task_is_readable(self, variable_write_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 391 | def test_scratch_variable_deleted_by_java_task_is_gone(self, variable_write_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 412 | def test_input_tasks_receive_their_bound_arguments(self, interface_example_run: _CompletedRun): | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 430 | def test_numeric_xcom_casting(self, xcom_casting_example_run: _CompletedRun): | 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_taskflow_binding.py | 120 | def test_upstream_xcoms_keep_their_shapes(completed_run: _CompletedRun): | CODE |
| LOW | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 131 | def test_via_flat_args_summary_reflects_bound_arguments(completed_run: _CompletedRun): | CODE |
| LOW | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 147 | def test_via_struct_no_tags_reflects_bound_arguments(completed_run: _CompletedRun): | CODE |
| LOW | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 159 | def test_via_struct_arg_tag_reflects_bound_arguments(completed_run: _CompletedRun): | CODE |
| LOW | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 170 | def test_via_struct_default_arg_tolerates_unclaimed_default(completed_run: _CompletedRun): | CODE |
| LOW | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 177 | def test_via_struct_more_args_warns_and_runs(completed_run: _CompletedRun): | CODE |
| LOW | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 188 | def test_via_struct_fewer_args_warns_and_runs(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 205 | def test_via_flat_map_decodes_single_dict_whole(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 211 | def test_via_struct_map_binds_single_dict_onto_map_field(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py | 219 | def test_via_plain_map_decodes_dict_into_a_typed_map(completed_run: _CompletedRun): | 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⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_task_state.py | 76 | def test_value_written_by_go_task_is_readable(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_task_state.py | 83 | def test_never_expire_key_has_null_expiry(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_task_state.py | 89 | def test_structured_value_roundtrips(completed_run: _CompletedRun): | CODE |
| LOW | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_task_state.py | 105 | def test_default_retention_applied(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 | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 112 | def test_the_dags_the_binary_parsed_are_registered(parsed_dags: AirflowClient): | CODE |
| LOW | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 120 | def test_the_graph_carries_every_construct(parsed_dags: AirflowClient): | CODE |
| LOW | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 143 | def test_the_taken_branches_ran_and_the_others_skipped(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 165 | def test_xcoms_flow_between_go_tasks(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 173 | def test_the_decisions_are_recorded(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 179 | def test_the_variable_and_connection_reached_the_go_task(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 184 | def test_a_task_pulls_the_xcom_another_pushed_under_its_own_key(completed_run: _CompletedRun): | CODE |
| LOW⚡ | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 190 | def test_the_dag_source_is_the_file_that_declares_the_dag(parsed_dags: AirflowClient): | CODE |
| LOW | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 201 | def test_the_trigger_started_the_report_run(parsed_dags: AirflowClient): | CODE |
| 30130 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 | # cap how many PRs a user without write access may have open at once | 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 | 1421 | # | COMMENT |
| LOW | pyproject.toml | 1441 | COMMENT | |
| LOW | pyproject.toml | 1461 | required-version = ">=0.11.8" | COMMENT |
| LOW | pyproject.toml | 1621 | apache-airflow-shared-state = false | 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/openlineage-compat-db.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/ts.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 | …/java-test-bundle/src/resources/dags/java_test_dags.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | 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 | 401 | # The example, scala_spark_example, and java-test-bundle are independent | 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/constants.py | 101 | # Far from the supervisor's own 30-day config fallback, so the e2e test can tell a | 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_taskflow_binding.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 | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_task_state.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 | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …w_e2e_tests/go_sdk_tests/test_go_sdk_variable_write.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 |
| 9142 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | clients/python/test_python_client.py | 27 | CODE | |
| LOW | …/java-test-bundle/src/resources/dags/java_test_dags.py | 19 | 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 | 68 | 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_taskflow_binding.py | 27 | CODE | |
| LOW | …_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py | 24 | CODE | |
| LOW | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_task_state.py | 23 | CODE | |
| LOW | …ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py | 66 | CODE | |
| LOW | …rflow_e2e_tests/go_sdk_tests/test_go_sdk_native_dag.py | 34 | CODE | |
| LOW | …w_e2e_tests/go_sdk_tests/test_go_sdk_variable_write.py | 24 | 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 | …sts/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_hitl.py | 51 | CODE | |
| LOW | …ests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_dag.py | 37 | 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_taskflow_example.py | 31 | 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 | ts-sdk/scripts/ci/prek/compile_ts_sdk.py | 18 | CODE | |
| LOW | ts-sdk/scripts/ci/prek/check_dag_schema.py | 18 | CODE | |
| LOW | ts-sdk/scripts/ci/prek/verify_ts_sdk_package.py | 18 | CODE | |
| LOW | …sdk/scripts/ci/prek/check_serialization_conformance.py | 20 | 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_jobs_command.py | 17 | CODE | |
| LOW | …tl/tests/airflow_ctl/ctl/commands/test_task_command.py | 17 | CODE | |
| LOW | …tl/tests/airflow_ctl/ctl/commands/test_auth_command.py | 17 | CODE | |
| 6877 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 272 | # 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 | 31 | 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 | 195 | 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 | 214 | 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 | 452 | 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 | 102 | 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 | 356 | 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 | 411 | 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 | 454 | 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 | 511 | 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 | 69 | from airflow.utils.helpers import exactly_one, prune_dict | CODE |
| CRITICAL | …low/providers/amazon/aws/operators/redshift_cluster.py | 40 | 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 | …azon/src/airflow/providers/amazon/aws/operators/ecr.py | 25 | 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 | …mazon/src/airflow/providers/amazon/aws/triggers/eks.py | 32 | 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 | 31 | 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 | 58 | from airflow.utils.helpers import merge_dicts, prune_dict | CODE |
| CRITICAL | …providers/amazon/aws/executors/batch/batch_executor.py | 43 | 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 | 52 | 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 | 176 | mock_client.secrets.kv.v2.read_secret_version.assert_has_calls( | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 207 | mock_client.secrets.kv.v2.read_secret_version.assert_has_calls( | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 288 | mock_client.secrets.kv.v2.read_secret_version.assert_not_called() | CODE |
| CRITICAL | …s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py | 368 | mock_client.secrets.kv.v2.read_secret_version.assert_has_calls( | CODE |
| 232 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 |
| 550 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 65 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 67 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 171 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 173 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 473 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 475 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 492 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 494 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 560 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 562 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 42 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 44 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 227 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …sk-sdk/tests/task_sdk/definitions/test_retry_policy.py | 229 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ests/unit/amazon/aws/auth_manager/routes/test_login.py | 250 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ests/unit/amazon/aws/auth_manager/routes/test_login.py | 252 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ests/unit/amazon/aws/auth_manager/routes/test_login.py | 393 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ests/unit/amazon/aws/auth_manager/routes/test_login.py | 395 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …low/providers/amazon/aws/executors/ecs/ecs_executor.py | 693 | # ── 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 | 2125 | # ------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 2127 | # ------------------------------------------------------------------------- | 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⚡ | …viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py | 50 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py | 52 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py | 118 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py | 120 | # ------------------------------------------------------------------ | 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 | 160 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 162 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 164 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 166 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 182 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 184 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 188 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 190 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 192 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 194 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 205 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 207 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 217 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 219 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 223 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 225 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 227 | # ============================================================================ | 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 | 233 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | …mmon/compat/src/airflow/providers/common/compat/sdk.py | 237 | # ============================================================================ | COMMENT |
| 608 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 901 | except Exception: | CODE |
| LOW | …/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py | 164 | except Exception as error: | 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 | 840 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 306 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 313 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 343 | except Exception as e: | CODE |
| LOW | airflow-ctl-tests/tests/airflowctl_tests/conftest.py | 398 | 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 | 2055 | except Exception as e: | CODE |
| LOW | task-sdk/tests/task_sdk/execution_time/test_comms.py | 167 | except Exception as e: | CODE |
| MEDIUM | task-sdk/tests/task_sdk/execution_time/test_comms.py | 163 | 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 | 248 | 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 | 667 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/plugins_manager.py | 98 | 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/coordinators/_subprocess.py | 446 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 636 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 647 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 686 | except Exception as e: | CODE |
| LOW | …sdk/src/airflow/sdk/coordinators/java/_dag_importer.py | 66 | except Exception: | CODE |
| LOW | …sdk/src/airflow/sdk/coordinators/java/_dag_importer.py | 72 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/importers/python_importer.py | 163 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/importers/python_importer.py | 189 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/importers/zip_importer.py | 184 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/importers/zip_importer.py | 202 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/importers/base.py | 465 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/importers/base.py | 474 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/importers/base.py | 608 | except Exception as err: | CODE |
| MEDIUM | task-sdk/src/airflow/sdk/importers/base.py | 114 | def freshness_token(self) -> str: | CODE |
| LOW | task-sdk/src/airflow/sdk/io/path.py | 162 | 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/coordinator.py | 359 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/comms.py | 406 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 412 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 503 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 578 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 590 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 673 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1132 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1166 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1292 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1497 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1707 | except Exception as e: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1864 | except Exception: | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1883 | except Exception: | CODE |
| 1228 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 724 | "pnpm install --frozen-lockfile && pnpm run build && cd example && pnpm install" | CODE |
| HIGH⚡ | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 725 | " && pnpm run build && pnpm run build:ai-approval" | CODE |
| 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 | 826 | # Return None (null) when no previous TI found | COMMENT |
| HIGH⚡ | task-sdk/tests/task_sdk/api/test_client.py | 1810 | # Return None (null) when no previous Dag run found | COMMENT |
| HIGH | task-sdk/tests/task_sdk/serde/test_serializers.py | 294 | assert i.equals(d) | CODE |
| HIGH | task-sdk/tests/task_sdk/serde/test_serializers.py | 313 | assert i.equals(d) | CODE |
| HIGH | task-sdk/src/airflow/sdk/bases/operator.py | 1555 | DagContext.push(None) | CODE |
| HIGH | task-sdk/src/airflow/sdk/definitions/dag.py | 757 | DagContext.push(self) | CODE |
| HIGH | task-sdk/src/airflow/sdk/definitions/taskgroup.py | 401 | TaskGroupContext.push(self) | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 142 | assert read_df.equals(test_df) | CODE |
| HIGH⚡ | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 246 | assert df.equals( | CODE |
| HIGH⚡ | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 256 | assert df.equals( | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 298 | assert df.equals( | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 340 | assert df.equals( | CODE |
| HIGH | …azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py | 350 | assert df.equals( | CODE |
| HIGH | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 602 | '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}', | STRING |
| HIGH | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 612 | '{"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 | 44 | backend_kwargs = {"connections_prefix": "/airflow/connections", "profile_name": null} | STRING |
| HIGH⚡ | …irflow/providers/amazon/aws/secrets/systems_manager.py | 52 | 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 | 58 | 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 | 64 | 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/duckdb.py | 97 | whether the key is present, so ``{"aws_conn_id": null}`` selects the ambient AWS environment. | STRING |
| HIGH | …mazon/src/airflow/providers/amazon/aws/hooks/duckdb.py | 148 | valid choice here and not the absence of one: ``{"aws_conn_id": null}`` in the ``extra`` | STRING |
| HIGH | …mazon/src/airflow/providers/amazon/aws/hooks/athena.py | 266 | 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 | 134 | f"count=$(($(stat -c '%s' {shlex.quote(file_path)})/4096+1)) 2>/dev/null; " | CODE |
| HIGH⚡ | …icorp/src/airflow/providers/hashicorp/secrets/vault.py | 55 | (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 | 58 | (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 | 61 | (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 | 47 | 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 | 132 | "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 | 68 | 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 | 70 | 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 | 73 | 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 | 72 | 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 | 74 | 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 | 76 | 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 | 150 | assert bash_task.operator.bash_command == "echo hello world && echo 2" | CODE |
| HIGH | …s/standard/tests/unit/standard/decorators/test_bash.py | 153 | self.validate_bash_command_rtif(ti, "echo hello world && echo 2") | CODE |
| 102 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 815 | CODE | |
| LOW | kubernetes-tests/tests/kubernetes_tests/test_base.py | 245 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 227 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 689 | CODE | |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 921 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 200 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 249 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/operations.py | 173 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 1013 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 543 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 750 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 846 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 850 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/commands/auth_command.py | 124 | CODE | |
| LOW | …flow-ctl/src/airflowctl/ctl/commands/config_command.py | 736 | CODE | |
| LOW | …flow-ctl/src/airflowctl/ctl/commands/config_command.py | 105 | CODE | |
| LOW | task-sdk/tests/conftest.py | 188 | CODE | |
| LOW | …k-sdk/tests/task_sdk/test_providers_manager_runtime.py | 317 | CODE | |
| LOW | task-sdk/tests/task_sdk/execution_time/test_tracing.py | 131 | CODE | |
| LOW | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 4958 | 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 | 462 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 517 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 631 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 484 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 536 | CODE | |
| LOW | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 671 | 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 | 81 | CODE | |
| LOW | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 204 | CODE | |
| LOW | task-sdk/src/airflow/sdk/importers/zip_importer.py | 85 | CODE | |
| LOW | task-sdk/src/airflow/sdk/importers/zip_importer.py | 121 | CODE | |
| LOW | task-sdk/src/airflow/sdk/importers/zip_importer.py | 167 | 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 | 311 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/operator.py | 2027 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 863 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1266 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1306 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1429 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1806 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 988 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1380 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1393 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1529 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 1692 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2330 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 2425 | CODE | |
| LOW | …/src/airflow/sdk/execution_time/callback_supervisor.py | 350 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 264 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 1640 | CODE | |
| LOW | task-sdk/src/airflow/sdk/execution_time/context.py | 1068 | CODE | |
| 973 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 | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 241 | # 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 | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 1042 | # Create a mock client to assert calls to the client | COMMENT |
| MEDIUM | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 1794 | # Create a fake placeholder in the open socket weakref | COMMENT |
| MEDIUM | …k-sdk/tests/task_sdk/execution_time/test_supervisor.py | 4898 | # Create a simple TaskInstance datamodel to pass to the supervisor | COMMENT |
| MEDIUM | task-sdk/tests/task_sdk/definitions/test_dag.py | 347 | # Create a linear chain: t1 -> t2 -> t3 -> t4 -> t5 | COMMENT |
| MEDIUM | task-sdk/tests/task_sdk/definitions/test_dag.py | 382 | # Create a diamond pattern: | COMMENT |
| MEDIUM | …-sdk/tests/task_sdk/definitions/test_mappedoperator.py | 831 | # 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 | 2596 | # 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 | 2654 | # 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 | 330 | # Create a deferred state payload from msg | COMMENT |
| MEDIUM | task-sdk/src/airflow/sdk/api/client.py | 342 | # 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 | 1160 | # Create a temporary credentials file | COMMENT |
| MEDIUM | …ers/amazon/tests/unit/amazon/aws/operators/test_eks.py | 1219 | # 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 | 186 | # Create a test file remotely | COMMENT |
| MEDIUM | …sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py | 193 | # Create a new Collection and verify it is empty. | COMMENT |
| MEDIUM | …sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py | 285 | # Create a new Collection and add a two tasks. | COMMENT |
| MEDIUM | …mazon/aws/executors/aws_lambda/test_lambda_executor.py | 1255 | # Create a team-specific executor. | COMMENT |
| MEDIUM | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 209 | # Create the local log file structure | COMMENT |
| MEDIUM | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 256 | # 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 | 93 | # 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 | 76 | # 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 | 91 | # 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 | 154 | # 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 |
| MEDIUM | …iders/amazon/tests/system/amazon/aws/example_lambda.py | 63 | # Create a zip file containing one file "lambda_function.py" to deploy to the lambda function | STRING |
| MEDIUM | …tem/amazon/aws/example_eks_with_fargate_in_one_step.py | 73 | # Create an Amazon EKS cluster control plane and an AWS Fargate compute platform in one step. | COMMENT |
| MEDIUM | …mazon/tests/system/amazon/aws/example_eks_templated.py | 66 | # Create an Amazon EKS Cluster control plane without attaching a compute service. | COMMENT |
| MEDIUM | providers/amazon/tests/system/amazon/aws/example_dms.py | 221 | # Create the Table. | COMMENT |
| MEDIUM | providers/amazon/tests/system/amazon/aws/utils/ec2.py | 164 | # Create the requested number of subnets. | COMMENT |
| MEDIUM | …ow/providers/amazon/aws/operators/neptune_analytics.py | 921 | # Create the console link | COMMENT |
| MEDIUM | …src/airflow/providers/amazon/aws/operators/datasync.py | 368 | # Create a task execution: | COMMENT |
| MEDIUM | …src/airflow/providers/amazon/aws/operators/datasync.py | 373 | # Create the execution extra link | COMMENT |
| MEDIUM | …/providers/amazon/aws/auth_manager/cli/avp_commands.py | 49 | # Create the policy store if needed | COMMENT |
| 210 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py | 272 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/operations.py | 562 | CODE | |
| LOW | airflow-ctl/src/airflowctl/api/operations.py | 633 | CODE | |
| LOW | airflow-ctl/src/airflowctl/ctl/cli_config.py | 138 | CODE | |
| LOW | task-sdk/tests/conftest.py | 230 | CODE | |
| LOW | task-sdk/tests/conftest.py | 250 | CODE | |
| LOW | task-sdk/tests/conftest.py | 273 | CODE | |
| LOW | task-sdk/tests/conftest.py | 318 | CODE | |
| LOW | …s/task_sdk/coordinators/executable/test_coordinator.py | 73 | CODE | |
| LOW | …task_sdk/coordinators/executable/_bundle_test_utils.py | 37 | CODE | |
| LOW | …tests/task_sdk/coordinators/node/_bundle_test_utils.py | 85 | CODE | |
| LOW | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 4522 | CODE | |
| LOW | …dk/tests/task_sdk/execution_time/test_email_backend.py | 30 | CODE | |
| LOW | task-sdk/dev/datamodel_code_formatter.py | 144 | CODE | |
| LOW | task-sdk/src/airflow/sdk/io/path.py | 62 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/sensor.py | 115 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/decorator.py | 478 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/operator.py | 297 | CODE | |
| LOW | task-sdk/src/airflow/sdk/bases/operator.py | 1051 | CODE | |
| LOW | task-sdk/src/airflow/sdk/api/client.py | 888 | CODE | |
| LOW | task-sdk/src/airflow/sdk/definitions/dag.py | 1595 | 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 | 228 | CODE | |
| LOW | …src/airflow/providers/docker/operators/docker_swarm.py | 133 | 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 | 100 | CODE | |
| LOW | …ests/unit/amazon/aws/auth_manager/routes/test_login.py | 148 | 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 | 180 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/dms.py | 914 | 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 | 127 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 310 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 563 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 780 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/emr.py | 1335 | CODE | |
| LOW | …low/providers/amazon/aws/operators/redshift_cluster.py | 160 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/eks.py | 84 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/eks.py | 276 | CODE | |
| LOW | …azon/src/airflow/providers/amazon/aws/operators/eks.py | 536 | CODE | |
| LOW | …on/src/airflow/providers/amazon/aws/operators/batch.py | 149 | CODE | |
| LOW | …airflow/providers/amazon/aws/operators/athena_spark.py | 65 | CODE | |
| LOW | …ow/providers/amazon/aws/operators/neptune_analytics.py | 103 | CODE | |
| LOW | …ow/providers/amazon/aws/operators/neptune_analytics.py | 624 | CODE | |
| LOW | …ow/providers/amazon/aws/operators/neptune_analytics.py | 867 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/mwaa.py | 89 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/glue.py | 185 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/glue.py | 684 | CODE | |
| LOW | …zon/src/airflow/providers/amazon/aws/operators/glue.py | 849 | CODE | |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 281 | CODE | |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 788 | CODE | |
| LOW | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 1224 | CODE | |
| LOW | …zon/aws/operators/sagemaker_unified_studio_notebook.py | 108 | CODE | |
| LOW | …src/airflow/providers/amazon/aws/operators/datasync.py | 147 | CODE | |
| 679 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | kubernetes-tests/tests/kubernetes_tests/test_base.py | 337 | except (MaxRetryError, RetryError): | CODE |
| HIGH | airflow-ctl/src/airflowctl/ctl/cli_config.py | 187 | except ValueError: | CODE |
| HIGH | task-sdk/tests/conftest.py | 224 | except (ImportError, AttributeError): | CODE |
| HIGH | task-sdk/src/airflow/sdk/configuration.py | 176 | except ImportError: | CODE |
| HIGH | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 96 | except ValueError: | CODE |
| HIGH | task-sdk/src/airflow/sdk/bases/operator.py | 220 | except RuntimeError: | CODE |
| HIGH | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 2925 | except (ImportError, AttributeError): | CODE |
| HIGH | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1262 | except (ProcessLookupError, PermissionError): | CODE |
| HIGH | task-sdk/src/airflow/sdk/execution_time/context.py | 235 | except SecretCache.NotPresentException: | CODE |
| HIGH | task-sdk/src/airflow/sdk/execution_time/context.py | 283 | except SecretCache.NotPresentException: | CODE |
| HIGH | task-sdk/src/airflow/sdk/execution_time/context.py | 374 | except SecretCache.NotPresentException: | CODE |
| HIGH | task-sdk/src/airflow/sdk/execution_time/context.py | 413 | except SecretCache.NotPresentException: | CODE |
| HIGH | task-sdk/src/airflow/sdk/api/client.py | 144 | except OSError: | CODE |
| HIGH | …ers/neo4j/src/airflow/providers/neo4j/sensors/neo4j.py | 89 | except Exception: | CODE |
| HIGH | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 2237 | except (ValueError, TypeError): | CODE |
| HIGH | …rc/airflow/providers/amazon/aws/operators/sagemaker.py | 2241 | except (ValueError, TypeError): | CODE |
| HIGH | …airflow/providers/amazon/aws/utils/task_log_fetcher.py | 69 | except (json.JSONDecodeError, AttributeError): | CODE |
| HIGH | …rc/airflow/providers/amazon/aws/transfers/sql_to_s3.py | 276 | except ImportError: | CODE |
| HIGH | …on/src/airflow/providers/amazon/aws/hooks/sagemaker.py | 605 | except logs_conn.exceptions.ResourceNotFoundException: | CODE |
| HIGH | …viders/edge3/src/airflow/providers/edge3/cli/worker.py | 249 | except RuntimeError: | CODE |
| HIGH | …ogle/tests/unit/google/cloud/triggers/test_bigquery.py | 260 | except (asyncio.CancelledError, StopAsyncIteration): | CODE |
| HIGH | …ers/google/marketing_platform/operators/bid_manager.py | 378 | except FileNotFoundError: | CODE |
| HIGH | …c/airflow/providers/google/cloud/sensors/datafusion.py | 118 | except HTTPError: | CODE |
| HIGH | …e/src/airflow/providers/google/cloud/hooks/bigquery.py | 1261 | except NotFound: | CODE |
| HIGH | …gle/src/airflow/providers/google/cloud/hooks/pubsub.py | 177 | except ValueError: | CODE |
| HIGH | …src/airflow/providers/google/cloud/hooks/datafusion.py | 136 | except (HTTPError, KeyError): | CODE |
| HIGH | …netes/tests/unit/cncf/kubernetes/operators/test_pod.py | 218 | except ImportError: | CODE |
| HIGH | …/cncf/kubernetes/decorators/test_kubernetes_commons.py | 125 | except ImportError: | CODE |
| HIGH | …irflow/providers/cncf/kubernetes/template_rendering.py | 47 | except (ImportError, AttributeError): | CODE |
| HIGH | …oviders/cncf/kubernetes/kubernetes_helper_functions.py | 92 | except ValueError: | CODE |
| HIGH | …src/airflow/providers/microsoft/azure/hooks/msgraph.py | 1022 | except RuntimeError: | CODE |
| HIGH | …low/providers/databricks/operators/databricks_repos.py | 116 | except ValueError: | CODE |
| HIGH | …/airflow/providers/databricks/hooks/databricks_base.py | 1467 | except JSONDecodeError: | CODE |
| HIGH | …/unit/fab/auth_manager/cli_commands/test_db_command.py | 165 | except (ModuleNotFoundError, ImportError): | CODE |
| HIGH | …ders/fab/tests/unit/fab/auth_manager/models/test_db.py | 397 | except ModuleNotFoundError: | CODE |
| HIGH | …roviders/fab/auth_manager/security_manager/override.py | 2672 | except (ValueError, AttributeError): | CODE |
| HIGH | providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 77 | except Exception: | CODE |
| HIGH | providers/ibm/mq/tests/conftest.py | 39 | except ImportError: | CODE |
| HIGH | …rflow/providers/common/ai/operators/document_loader.py | 247 | except FileNotFoundError: | CODE |
| HIGH | …mmon/ai/src/airflow/providers/common/ai/utils/usage.py | 129 | except ValueError: | CODE |
| HIGH | …src/airflow/providers/common/ai/utils/file_analysis.py | 273 | except FileNotFoundError: | CODE |
| HIGH | …ers/common/ai/example_dags/example_llm_retry_policy.py | 173 | except ImportError: | CODE |
| HIGH | …mmon/ai/src/airflow/providers/common/ai/sandbox/sbx.py | 554 | except subprocess.TimeoutExpired: | CODE |
| HIGH | …on/ai/src/airflow/providers/common/ai/sandbox/modal.py | 544 | except modal.exception.NotFoundError: | CODE |
| HIGH | …mmon/sql/src/airflow/providers/common/sql/hooks/sql.py | 399 | except (ArgumentError, NoSuchModuleError, ValueError): | CODE |
| HIGH | …h/src/airflow/providers/ssh/triggers/ssh_remote_job.py | 146 | except Exception: | CODE |
| HIGH | …ess/src/airflow/providers/akeyless/secrets/akeyless.py | 296 | except (json.JSONDecodeError, TypeError): | CODE |
| HIGH | …ess/src/airflow/providers/akeyless/secrets/akeyless.py | 313 | except (json.JSONDecodeError, TypeError): | CODE |
| HIGH | …ineage/tests/unit/openlineage/plugins/test_listener.py | 132 | except Exception: | CODE |
| HIGH | …iders/openlineage/tests/system/openlineage/operator.py | 54 | except Exception: | CODE |
| HIGH | …iders/openlineage/tests/system/openlineage/operator.py | 63 | except Exception: | CODE |
| HIGH | …iders/openlineage/tests/system/openlineage/operator.py | 72 | except Exception: | CODE |
| HIGH | …iders/openlineage/tests/system/openlineage/operator.py | 81 | except Exception: | CODE |
| HIGH | …ery/src/airflow/providers/celery/cli/celery_command.py | 300 | except sqlalchemy.exc.IntegrityError: | CODE |
| HIGH | …irflow/providers/keycloak/auth_manager/cli/commands.py | 1049 | except KeycloakError: | CODE |
| HIGH | …viate/src/airflow/providers/weaviate/hooks/weaviate.py | 79 | except ImportError: | CODE |
| HIGH | …nfiguration/src/airflow_shared/configuration/parser.py | 2078 | except JSONDecodeError: | CODE |
| HIGH | …lity/src/airflow_shared/observability/metrics/stats.py | 211 | except TypeError: | CODE |
| HIGH | …rc/airflow_shared/observability/metrics/otel_logger.py | 526 | except (ImportError, AttributeError): | CODE |
| HIGH | …ared/logging/src/airflow_shared/logging/_noncaching.py | 34 | except Exception: | CODE |
| 68 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | airflow-ctl/src/airflowctl/api/client.py | 84 | __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/types.py | 184 | def update_dagrun_note(self, note: str | None) -> None: ... | 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 | task-sdk/src/airflow/sdk/coordinators/_subprocess.py | 178 | def _set_close_on_exec_above_stderr() -> None: | 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/importers/__init__.py | 39 | __all__ = [ | 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 | 1455 | def _set_xcomargs_dependencies(self) -> None: | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/bases/operator.py | 1463 | 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 | 58 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/bundles.py | 39 | __all__ = ["initialize_ti_bundle", "verify_bundle_access"] | CODE |
| LOW⚡ | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 275 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/execution_time/task_runner.py | 720 | def update_dagrun_note(self, note: str | None) -> None: | CODE |
| LOW | …/src/airflow/sdk/execution_time/callback_supervisor.py | 74 | __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 | 495 | 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 | 185 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/dag.py | 90 | __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 | 41 | __all__ = [ | CODE |
| LOW | task-sdk/src/airflow/sdk/definitions/deadline.py | 36 | 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 |
| 406 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ts-sdk/example/src/main.ts | 82 | await store.set(JOB_ID_KEY, "placeholder"); | CODE |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 4068 | 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 | 4068 | 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 | 149 | 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 | 309 | pods.metadata._continue = "dummy-token" | CODE |
| LOW | …ts/unit/cncf/kubernetes/cli/test_kubernetes_command.py | 324 | _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⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1177 | "toRecipients": [{"emailAddress": {"address": "user@example.com"}}], | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1190 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1203 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1231 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1248 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1260 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1270 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1280 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1295 | to="user@example.com", | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1307 | send_email(to="user@example.com", subject="Airflow alert", html_content="Something happened") | CODE |
| LOW⚡ | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1314 | to="user@example.com", | CODE |
| LOW | …azure/tests/unit/microsoft/azure/hooks/test_msgraph.py | 1160 | to="user@example.com", | CODE |
| LOW | …sts/unit/microsoft/azure/notifications/test_msgraph.py | 34 | TO_EMAIL = "user@example.com" | CODE |
| LOW | …cks/tests/unit/databricks/operators/test_databricks.py | 176 | "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 | …/tests/unit/fab/auth_manager/models/test_user_model.py | 45 | assert user.get_display_name() == "Jane Doe" | 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 | 1552 | assert token == "dummy_token" | CODE |
| LOW⚡ | …snowflake/tests/unit/snowflake/hooks/test_snowflake.py | 1567 | json=lambda: {"access_token": "dummy_token", "expires_in": 600}, | CODE |
| LOW | …snowflake/tests/unit/snowflake/hooks/test_snowflake.py | 1530 | json=lambda: {"access_token": "dummy_token", "expires_in": 600}, | CODE |
| LOW | …snowflake/tests/unit/snowflake/hooks/test_snowflake.py | 1584 | assert token == "dummy_token" | CODE |
| LOW | providers/jdbc/tests/unit/jdbc/hooks/test_jdbc.py | 294 | "placeholder": "?", | CODE |
| LOW⚡ | …mpat/tests/unit/common/compat/lineage/test_entities.py | 48 | (User, ("user@example.com",)), | CODE |
| LOW⚡ | …mpat/tests/unit/common/compat/lineage/test_entities.py | 73 | user = User(email="user@example.com") | CODE |
| 267 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 | 2592 | # 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/bases/decorator.py | 223 | # Check if args conflict with names in kwargs. | COMMENT |
| LOW | task-sdk/src/airflow/sdk/execution_time/supervisor.py | 1426 | # Check if the subprocess has exited | COMMENT |
| LOW | task-sdk/src/airflow/sdk/definitions/taskgroup.py | 385 | # Check if the current TaskGroup is empty | COMMENT |
| LOW | …/airflow/sdk/definitions/_internal/abstractoperator.py | 242 | # 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 | 1267 | # 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 | 104 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py | 177 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py | 235 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py | 293 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py | 127 | # Check if object was created in s3 | COMMENT |
| LOW | …zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py | 218 | # 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 | 881 | # 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 | 1288 | # 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 | 105 | # Read the file content in chunks using StreamingBody | COMMENT |
| LOW | …low/providers/amazon/aws/executors/ecs/ecs_executor.py | 128 | # 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 | 118 | # 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 | 99 | # 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 | 554 | # Check if permissions were set correctly | COMMENT |
| LOW | …adata/src/airflow/providers/teradata/operators/bteq.py | 44 | # 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 | 78 | # Check if shred is available | COMMENT |
| LOW | …adata/src/airflow/providers/teradata/utils/tpt_util.py | 111 | # 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 | 954 | # Check if the job-run duration has exceeded the ``timeout`` configured. | COMMENT |
| LOW | …irflow/providers/edge3/plugins/edge_executor_plugin.py | 58 | # Check if EdgeExecutor is actually loaded | COMMENT |
| LOW | …src/airflow/providers/edge3/executors/edge_executor.py | 94 | # 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 | 172 | # 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 | 291 | # Check if worker exists first | COMMENT |
| LOW | …ider_resource_cleanup/commands/cmd_list_asset_types.py | 97 | # Check if this is the last item in the list | 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 | 982 | # Check if cluster is not in ERROR state. | COMMENT |
| LOW | …airflow/providers/google/cloud/transfers/gcs_to_gcs.py | 302 | # Check if prefix contains wildcard | COMMENT |
| LOW | …e/src/airflow/providers/google/cloud/hooks/bigquery.py | 321 | # Check if tableReference is present and is valid | COMMENT |
| LOW | …e/src/airflow/providers/google/cloud/hooks/bigquery.py | 328 | # Check if value is already present if no use the provided one | COMMENT |
| LOW⚡ | …c/airflow/providers/google/cloud/openlineage/mixins.py | 507 | # 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 | 516 | # Verify if all columns from parse results are present in the output dataset schema | COMMENT |
| LOW⚡ | …c/airflow/providers/google/cloud/openlineage/mixins.py | 525 | # Verify if all datasets from parse results are present in bq job input datasets | COMMENT |
| LOW⚡ | …c/airflow/providers/google/cloud/openlineage/mixins.py | 529 | # 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 |
| LOW | …ogle/src/airflow/providers/google/suite/hooks/drive.py | 125 | # Check if there are directories to process | STRING |
| 155 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 | 480 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 491 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 502 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 511 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 521 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 670 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 679 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 688 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 698 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 708 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 864 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 881 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 957 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 974 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1255 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1264 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1273 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1282 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1291 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1300 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1309 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1318 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1329 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1338 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1347 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1435 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1445 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1786 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1795 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1804 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1813 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1822 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1831 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 1841 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 2086 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 2095 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 2104 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 2113 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 2122 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 2131 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 2142 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 398 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 407 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 421 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 435 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 460 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 469 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 532 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 547 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 558 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 576 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 589 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 599 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 657 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 737 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 753 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 777 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 842 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| LOW | airflow-ctl/tests/airflow_ctl/api/test_operations.py | 853 | def handle_request(request: httpx.Request) -> httpx.Response: | CODE |
| 180 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 760 | # Step 1: Simulate CLI args being parsed (logical_date=None) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 785 | # Step 3: Create the Pydantic model (what happens in the actual code) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 788 | # Step 4: Verify logical_date was set to now | COMMENT |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 774 | # 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 | 682 | # Step 1: create the dag run span and capture its carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 689 | # 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 | 699 | # Step 3: build StartupDetails with ti.context_carrier = ti_carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 718 | # Step 4: emit the worker span (task runner side). | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 724 | # 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 | 1125 | # 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 | 447 | # Step 1: Build the AIP list from the registry, using Confluence page | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 481 | # Step 2: Fetch the repo file tree from GitHub once, shared across | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 518 | # Step 3: Gather evidence from Confluence, GitHub, and the file tree. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 628 | # Step 4: Format the gathered evidence into an LLM analysis prompt. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 654 | # Step 5: Analyze each AIP with a structured LLM call. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 670 | # Step 6: Collect all per-AIP analyses into a combined context. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 687 | # Step 7: Format the structured analyses as readable markdown. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 738 | # Step 8: Synthesize a cross-AIP progress report. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 764 | # Step 9: AI-powered hallucination validation. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 796 | # Step 10: Apply validation corrections deterministically. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 876 | # Step 11: Build the review body for the human reviewer, showing | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 915 | # 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 | 760 | # Step 1: Simulate CLI args being parsed (logical_date=None) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 785 | # Step 3: Create the Pydantic model (what happens in the actual code) | COMMENT |
| LOW⚡ | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 788 | # Step 4: Verify logical_date was set to now | COMMENT |
| LOW | airflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py | 774 | # 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 | 682 | # Step 1: create the dag run span and capture its carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 689 | # 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 | 699 | # Step 3: build StartupDetails with ti.context_carrier = ti_carrier. | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 718 | # Step 4: emit the worker span (task runner side). | COMMENT |
| LOW⚡ | …-sdk/tests/task_sdk/execution_time/test_task_runner.py | 724 | # 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 | 447 | # Step 1: Build the AIP list from the registry, using Confluence page | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 481 | # Step 2: Fetch the repo file tree from GitHub once, shared across | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 518 | # Step 3: Gather evidence from Confluence, GitHub, and the file tree. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 628 | # Step 4: Format the gathered evidence into an LLM analysis prompt. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 654 | # Step 5: Analyze each AIP with a structured LLM call. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 670 | # Step 6: Collect all per-AIP analyses into a combined context. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 687 | # Step 7: Format the structured analyses as readable markdown. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 738 | # Step 8: Synthesize a cross-AIP progress report. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 764 | # Step 9: AI-powered hallucination validation. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 796 | # Step 10: Apply validation corrections deterministically. | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 876 | # Step 11: Build the review body for the human reviewer, showing | COMMENT |
| LOW⚡ | …common/ai/example_dags/example_aip_progress_tracker.py | 915 | # 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: Compare the downloaded CSV schema against the reference. | STRING |
| 18 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | .pre-commit-config.yaml | 420 | # check when the shared harness or Airflow's serializer changes, which that project cannot see. | COMMENT |
| 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 | 832 | # so it must not also load the stock e2e dags, since 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 | 86 | # Essentially similar to airflow.models.baseoperator.BaseOperator | COMMENT |
| LOW | task-sdk/src/airflow/sdk/execution_time/comms.py | 236 | # `__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 | 2728 | # 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 | 268 | # 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 | 495 | # 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 | providers/common/ai/pyproject.toml | 114 | # pydantic-ai-harness is pre-1.0; an opt-in extra so its churn never breaks the | COMMENT |
| MEDIUM⚡ | …common/ai/tests/unit/common/ai/operators/test_agent.py | 1287 | # touch the harness root, whose CodeMode export would raise ImportError here. | 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 | …openai/src/airflow/providers/openai/triggers/openai.py | 88 | # Measure elapsed time with time.monotonic() so the timeout is robust | 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 | 324 | # 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 | 1524 | # 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 | 408 | # 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 | 505 | """Yield this event in order to end the task successfully.""" | STRING |
| MEDIUM⚡ | airflow-core/src/airflow/triggers/base.py | 511 | """Yield this event in order to end the task with failure.""" | STRING |
| MEDIUM⚡ | airflow-core/src/airflow/triggers/base.py | 517 | """Yield this event in order to end the task with status 'skipped'.""" | STRING |
| LOW | airflow-core/src/airflow/serialization/encoders.py | 421 | # values, so we can just use the first to represent them. | COMMENT |
| LOW | airflow-core/src/airflow/utils/db.py | 1533 | # 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 | 372 | # 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 |
| MEDIUM | dev/breeze/src/airflow_breeze/utils/selective_checks.py | 523 | # Airflow's serializer and schema, and the shared harness. | COMMENT |
| MEDIUM | dev/breeze/src/airflow_breeze/utils/selective_checks.py | 1297 | # matrix: the shared e2e harness (conftest / constants) or the compat Dockerfile. The compat | COMMENT |
| MEDIUM | dev/breeze/src/airflow_breeze/utils/selective_checks.py | 1957 | # harness changed. Those last do not force full_tests_needed, so they need their own group. | COMMENT |
| LOW | dev/breeze/src/airflow_breeze/params/shell_params.py | 534 | # Socket is something different (TCP?) just pass it through as DOCKER_HOST variable | COMMENT |
| MEDIUM | …airflow_breeze/commands/release_management_commands.py | 2275 | """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 | 114 | # If you are updating here don't forget to update the airflow-ctl-tests | COMMENT |
| LOW | airflow-ctl/src/airflowctl/api/client.py | 114 | # 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 | 415 | # 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 | 1290 | # 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 | 70 | # 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 | 50 | # If you prefer, you can add an alias run_query = run in your hook. | COMMENT |
| MEDIUM | providers/openai/tests/system/openai/example_openai.py | 23 | # If you only need Airflow 3+, you can use: from airflow.sdk import dag, task | COMMENT |
| MEDIUM | chart/values.yaml | 490 | # or, you can use a different database like: | COMMENT |
| MEDIUM | chart/values.yaml | 590 | # 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 | 53 | # 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 | 53 | # 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 | 63 | # Therefore you can add the "section" attribute. | COMMENT |
| MEDIUM | …src/airflow/example_dags/example_params_ui_tutorial.py | 65 | # 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 | 80 | # 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 | 192 | # then you can use the examples feature of JSON schema | COMMENT |
| MEDIUM | …src/airflow/example_dags/example_params_ui_tutorial.py | 312 | # 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 |
|---|---|---|---|---|
| MEDIUM | pyproject.toml | 760 | # FastAPI dependency injection uses function calls in argument defaults intentionally. | COMMENT |
| MEDIUM | pyproject.toml | 836 | # Annotated is central for FastAPI dependency injection, skipping rules for FastAPI folders. | COMMENT |
| MEDIUM | .apache-magpie-overrides/project.md | 25 | [`docs/setup/agentic-overrides.md`](https://github.com/apache/magpie/blob/main/docs/setup/agentic-overrides.md). | CODE |
| 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 | …e-magpie-overrides/pr-management-quick-merge-config.md | 36 | - [Note on automated merge (Agentic Autonomous)](#note-on-automated-merge-agentic-autonomous) | CODE |
| MEDIUM | …viders/amazon/tests/system/amazon/aws/utils/bedrock.py | 68 | # RAG may not support yet, and picks the same one on every run. | COMMENT |
| MEDIUM | …viders/amazon/tests/system/amazon/aws/utils/bedrock.py | 85 | # Haiku has some version dependency issues: RAG only supports 3.5 but batch only supports 4.5 | COMMENT |
| MEDIUM⚡ | …/google/tests/system/google/cloud/gen_ai/llm_models.py | 44 | # embedding model with text support | COMMENT |
| MEDIUM | …compat/src/airflow/providers/common/compat/triggers.py | 29 | # Airflow 3.0 added BaseEventTrigger to mark triggers usable as event-driven scheduling sources. | COMMENT |
| MEDIUM | …/unit/common/ai/operators/test_llamaindex_retrieval.py | 89 | # The retrieval-time embedding model is passed directly (no Settings mutation). | COMMENT |
| MEDIUM | …common/ai/tests/unit/common/ai/hooks/test_langchain.py | 101 | # extra placeholder shows both chat and embedding model keys | COMMENT |
| MEDIUM | …src/airflow/providers/common/ai/utils/query_results.py | 47 | # unaffected, small enough that no single tool result can dominate the context window. | 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⚡ | …s/common/ai/example_dags/example_agent_capabilities.py | 120 | # 4. Input guardrails: reject unsafe input before the agent run starts | 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 | 764 | # Step 9: AI-powered hallucination validation. | COMMENT |
| MEDIUM | …irflow/providers/common/ai/example_dags/example_llm.py | 138 | # tokens, or 1_000 output tokens. Useful for guardrails on shared | COMMENT |
| MEDIUM | airflow-core/src/airflow/models/trigger.py | 460 | # 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 | 102 | # so each worktree (e.g. parallel agentic runs) gets its own environment tied to | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …radata/src/airflow/providers/teradata/operators/tpt.py | 177 | 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 | 581 | 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 | 315 | 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 | 301 | 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 | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 578 | CODE | |
| MEDIUM | …ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py | 591 | CODE | |
| MEDIUM | …es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 1568 | CODE | |
| MEDIUM | …es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py | 1762 | CODE | |
| MEDIUM | …ers/standard/tests/unit/standard/triggers/test_file.py | 260 | CODE | |
| MEDIUM | …s/common/ai/tests/unit/common/ai/tools/test_strands.py | 59 | CODE | |
| MEDIUM | …erg/tests/unit/apache/iceberg/triggers/test_iceberg.py | 89 | CODE | |
| MEDIUM | …rflow/providers/apache/kafka/triggers/shared_stream.py | 403 | 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 | 1257 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 651 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 722 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 738 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 764 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 937 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 954 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 1295 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_mappedoperator.py | 1342 | CODE | |
| MEDIUM | airflow-core/tests/unit/models/test_dagrun.py | 4212 | CODE | |
| MEDIUM | airflow-core/src/airflow/triggers/base.py | 197 | CODE | |
| MEDIUM | airflow-core/src/airflow/triggers/base.py | 402 | CODE | |
| MEDIUM | airflow-core/src/airflow/triggers/base.py | 445 | 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 | 937 | :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 | 152 | # In this example we have no default value | COMMENT |