Repository Analysis

apache/airflow

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

24.2 Moderate AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of apache/airflow, a Python project with 46,111 GitHub stars. SynthScan v2.0 examined 2,017,942 lines of code across 10277 source files, recording 43508 pattern matches distributed across 25 syntactic categories. The overall adjusted score of 24.2 places this repository in the Moderate AI signal band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

24.2
Adjusted Score
24.2
Raw Score
100%
Time Factor
2026-07-14
Last Push
46.1K
Stars
Python
Language
2.0M
Lines of Code
10.3K
Files
43.5K
Pattern Hits
2026-07-14
Scan Date
0.10
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 262HIGH 718MEDIUM 1066LOW 41462

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 43508 distinct pattern matches across 25 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Hyper-Verbose Identifiers22867 hits · 21029 pts
SeverityFileLineSnippetContext
LOWclients/python/README.md297def get_airflow_client_access_token(CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py85def _copy_elasticsearch_files(tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py111def _setup_elasticsearch_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py126def _setup_opensearch_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py157def _write_providers_mount_override(tmp_dir: Path, providers: list[str]) -> list[str]:CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py185def _setup_event_driven_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py234def _setup_xcom_object_storage_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py284def _run_java_sdk_gradle_container(workdir, *gradle_argv, capture_output=False):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py344def _setup_java_sdk_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py471def _setup_go_sdk_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py571def _setup_openlineage_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py586def spin_up_airflow_environment(tmp_path_factory: pytest.TempPathFactory):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py698def pytest_runtest_makereport(item, call):CODE
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py112 def test_remote_logging_error_detail(self):CODE
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py46def create_request_session_with_retries(status_forcelist: list[int]):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py80 def test_java_tasks_execute_successfully(self, dag_id: str):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py115 def test_transform_xcom_is_numeric_timestamp(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py143 def test_concurrent_client_calls_succeed(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py168 def test_numeric_xcom_casting(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py194 def test_load_retried_then_succeeded(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py228 def _wait_for_transform_log_record(CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py251 def test_application_logs_preserve_their_level(self):CODE
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py56def pull_value_from_bash_push(ti=None):CODE
LOW…_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py77def test_concurrent_faster_than_sequential(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py161def test_load_retried_then_succeeded(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py187def 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.py203def test_xcom_crosses_go_to_python(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py208def test_extract_logs_show_beep_loop(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py216def test_extract_logs_show_runtime_context(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py259def test_transform_logs_show_variable_read(completed_run: _CompletedRun):CODE
LOW…ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py62def test_all_openlineage_dags_succeed(compose_instance, airflow_dags_path, airflow_logs_path):CODE
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py56def discover_expected_dag_ids(dags_folder: Path) -> set[str]:CODE
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py122 def wait_for_dag_run_to_complete(self, dag_id: str, run_id: str, timeout: int = 300) -> str:CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py52 def _wait_for_kafka_consumer_group(self, compose_instance, timeout: int = 60, check_interval: int = 3):CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py73 def _wait_for_consumer_dag_runs(CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py138 def test_producer_triggers_consumer_and_kafka_offsets(self, compose_instance):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py58 def test_integration_run_dag_task_mapping(self):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py82 def test_integration_run_dag_with_scheduler_failure(self):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py112 def test_pod_failure_logging_with_container_terminated(self, mock_log):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py173 def test_pod_failure_logging_exception_handling(self, mock_log):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py209 def test_pod_failure_logging_non_failed_state(self, mock_log):CODE
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py27def initialize_providers_manager():CODE
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py44def create_connection_without_db(monkeypatch):CODE
LOW…s-tests/tests/kubernetes_tests/test_other_executors.py52 def test_integration_run_dag_with_scheduler_failure(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py180 def test_do_xcom_push_defaults_false(self, kubeconfig_path, tmp_path):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py268 def test_skip_on_specified_exit_code(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py284 def test_already_checked_on_success(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py306 def test_already_checked_on_failure(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py624 def test_disable_privilege_escalation(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py666 def test_faulty_service_account(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py755 def test_pod_template_file_system(self, basic_pod_template):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py778 def test_pod_template_file_with_overrides_system(self, env_vars, test_label, basic_pod_template):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py805 def test_pod_template_file_with_full_pod_spec(self, test_label, basic_pod_template):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1068 def test_pod_priority_class_name(self, hook_mock, await_pod_completion_mock):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1158 def test_reattach_failing_pod_once(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1225 def test_changing_base_container_name_with_get_logs(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1250 def test_changing_base_container_name_no_logs(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1280 def test_changing_base_container_name_no_logs_long(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1311 def test_changing_base_container_name_failure(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py1338 def test_base_container_name_init_precedence(self):CODE
22807 more matches not shown…
Over-Commented Block8423 hits · 8236 pts
SeverityFileLineSnippetContext
LOW.asf.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.asf.yaml81COMMENT
LOWcodecov.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.hadolint.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWpyproject.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWpyproject.toml901# Deprecated importsCOMMENT
LOW.readthedocs.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.gitpod.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWyamllint-config.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.markdownlint.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.cherry_picker.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWclients/python/pyproject.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWclients/python/test_python_client.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWclients/python/test_python_client.py41except ImportError:COMMENT
LOWairflow-e2e-tests/.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/pyproject.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/kafka.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/go.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/localstack.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/Dockerfile.java1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/java.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/openlineage.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/openlineage.yml21# openlineage_tests/prepare_dags.py (conftest._setup_openlineage_integration). They emit through theCOMMENT
LOWairflow-e2e-tests/docker/openlineage.yml41 AIRFLOW__OPENLINEAGE__EXECUTION_TIMEOUT: '60'COMMENT
LOWairflow-e2e-tests/docker/opensearch.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/elasticsearch.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/kafka/update_run.sh1#!/bin/shCOMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py481 without a Go toolchain or any extra runtime installed -- see ``go.yml``.COMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/constants.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…sts/tests/airflow_e2e_tests/e2e_test_utils/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…sts/tests/airflow_e2e_tests/java_sdk_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py41# "extra": {COMMENT
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…asticsearch_tests/test_remote_logging_elasticsearch.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…w_e2e_tests/remote_log_elasticsearch_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…tests/tests/airflow_e2e_tests/go_sdk_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ject_storage_tests/test_xcom_object_storage_backend.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…irflow_e2e_tests/xcom_object_storage_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/remote_log_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…flow_e2e_tests/remote_log_tests/test_remote_logging.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…tests/airflow_e2e_tests/openlineage_tests/task_logs.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…/tests/airflow_e2e_tests/openlineage_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…openlineage_tests/dags_extra/openlineage_warmup_dag.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/openlineage_tests/dags_extra/e2e_versioned_bundle.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…tests/airflow_e2e_tests/event_driven_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…flow_e2e_tests/remote_log_opensearch_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…log_opensearch_tests/test_remote_logging_opensearch.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
8363 more matches not shown…
Unused Imports6189 hits · 5896 pts
SeverityFileLineSnippetContext
LOWclients/python/test_python_client.py27CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py17CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/constants.py17CODE
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py17CODE
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py17CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py55CODE
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py18CODE
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py19CODE
LOW…asticsearch_tests/test_remote_logging_elasticsearch.py17CODE
LOW…_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py24CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py66CODE
LOW…ject_storage_tests/test_xcom_object_storage_backend.py17CODE
LOW…flow_e2e_tests/remote_log_tests/test_remote_logging.py17CODE
LOW…ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py17CODE
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py26CODE
LOW…ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py31CODE
LOW…tests/airflow_e2e_tests/openlineage_tests/task_logs.py26CODE
LOW…openlineage_tests/dags_extra/openlineage_warmup_dag.py24CODE
LOW…s/openlineage_tests/dags_extra/e2e_versioned_bundle.py31CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py24CODE
LOW…log_opensearch_tests/test_remote_logging_opensearch.py17CODE
LOW…sts/airflow_e2e_tests/basic_tests/test_example_dags.py18CODE
LOW…low_e2e_tests/basic_tests/test_basic_dag_operations.py17CODE
LOWts-sdk/example/dags/typescript_example.py18CODE
LOWts-sdk/scripts/ci/prek/ts_sdk_lint.py18CODE
LOWts-sdk/scripts/ci/prek/check_supervisor_schema.py18CODE
LOWkubernetes-tests/lang_sdk/stage_artifacts.py41CODE
LOWkubernetes-tests/lang_sdk/dags/lang_sdk_combined.py37CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py17CODE
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py17CODE
LOW…s-tests/tests/kubernetes_tests/test_other_executors.py17CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py17CODE
LOW…kubernetes_tests/test_lang_sdk_coordinator_executor.py30CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py17CODE
LOWairflow-ctl/tests/conftest.py18CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py18CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_client.py18CODE
LOW…w-ctl/tests/airflow_ctl/ctl/test_console_formatting.py17CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py18CODE
LOW…ests/airflow_ctl/ctl/commands/test_variable_command.py17CODE
LOW…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py19CODE
LOW…s/airflow_ctl/ctl/commands/test_connections_command.py17CODE
LOW…/tests/airflow_ctl/ctl/commands/test_config_command.py17CODE
LOW…tests/airflow_ctl/ctl/commands/test_version_command.py17CODE
LOW…ctl/tests/airflow_ctl/ctl/commands/test_dag_command.py17CODE
LOW…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py17CODE
LOWairflow-ctl/docs/conf.py21CODE
LOW…iagrams/airflowctl_api_network_architecture_diagram.py17CODE
LOWairflow-ctl/src/airflowctl/__init__.py18CODE
LOWairflow-ctl/src/airflowctl/exceptions.py22CODE
LOWairflow-ctl/src/airflowctl/__main__.py22CODE
LOWairflow-ctl/src/airflowctl/utils/helpers.py18CODE
LOWairflow-ctl/src/airflowctl/utils/module_loading.py18CODE
LOWairflow-ctl/src/airflowctl/api/client.py18CODE
LOWairflow-ctl/src/airflowctl/api/operations.py18CODE
LOWairflow-ctl/src/airflowctl/api/datamodels/generated.py5CODE
LOW…ow-ctl/src/airflowctl/api/datamodels/auth_generated.py5CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py21CODE
LOWairflow-ctl/src/airflowctl/ctl/__init__.py20CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_parser.py25CODE
6129 more matches not shown…
Cross-File Repetition571 hits · 2855 pts
SeverityFileLineSnippetContext
HIGHairflow-ctl/src/airflowctl/utils/helpers.py0use a predicate to partition entries into false entries and true entriesSTRING
HIGHairflow-core/src/airflow/utils/helpers.py0use a predicate to partition entries into false entries and true entriesSTRING
HIGHdevel-common/src/docs/build_docs.py0use a predicate to partition entries into false entries and true entriesSTRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so pleSTRING
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so pleSTRING
HIGHairflow-core/src/airflow/utils/state.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so pleSTRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wiSTRING
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wiSTRING
HIGHairflow-core/src/airflow/utils/state.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wiSTRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0request body for setting an asset state store value.STRING
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0request body for setting an asset state store value.STRING
HIGH…_fastapi/execution_api/datamodels/asset_state_store.py0request body for setting an asset state store value.STRING
HIGH…w/api_fastapi/core_api/datamodels/asset_state_store.py0request body for setting an asset state store value.STRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of aSTRING
HIGH…src/airflow/api_fastapi/core_api/datamodels/dag_run.py0task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of aSTRING
HIGH…flow/api_fastapi/core_api/datamodels/task_instances.py0task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of aSTRING
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly STRING
HIGHairflow-core/src/airflow/utils/yaml.py0use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly STRING
HIGHtask-sdk/src/airflow/sdk/yaml.py0use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly STRING
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.STRING
HIGHtask-sdk/src/airflow/sdk/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.STRING
HIGHairflow-core/src/airflow/utils/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.STRING
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.STRING
HIGHtask-sdk/src/airflow/sdk/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.STRING
HIGHairflow-core/src/airflow/utils/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.STRING
HIGHtask-sdk/tests/task_sdk/bases/test_operator.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGH…elery/tests/integration/celery/test_celery_executor.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGH…ore/tests/unit/serialization/test_dag_serialization.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGHairflow-core/tests/unit/models/test_renderedtifields.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGHtask-sdk/tests/task_sdk/definitions/test_callback.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGH…re/tests/unit/serialization/test_serialized_objects.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_dag.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_deadline.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_serialized_dag.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_dagrun.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHtask-sdk/src/airflow/sdk/bases/notifier.py0template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :parSTRING
HIGHtask-sdk/src/airflow/sdk/bases/operator.py0template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :parSTRING
HIGHairflow-core/src/airflow/triggers/base.py0template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :parSTRING
HIGHtask-sdk/src/airflow/sdk/bases/hook.py0return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbapSTRING
HIGH…/sql/src/airflow/providers/common/sql/operators/sql.py0return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbapSTRING
HIGH…low/providers/common/sql/operators/generic_transfer.py0return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbapSTRING
HIGHtask-sdk/src/airflow/sdk/execution_time/task_runner.py0get the previous dag run before the given logical date, optionally filtered by state.STRING
HIGHtask-sdk/src/airflow/sdk/api/client.py0get the previous dag run before the given logical date, optionally filtered by state.STRING
HIGH…c/airflow/api_fastapi/execution_api/routes/dag_runs.py0get the previous dag run before the given logical date, optionally filtered by state.STRING
HIGHtask-sdk/src/airflow/sdk/definitions/deadline.py0a deadline that calculates the average runtime from past dag runs.STRING
HIGH…core/src/airflow/serialization/definitions/deadline.py0a deadline that calculates the average runtime from past dag runs.STRING
HIGHairflow-core/src/airflow/models/deadline.py0a deadline that calculates the average runtime from past dag runs.STRING
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:STRING
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:STRING
HIGH…/src/airflow/serialization/definitions/baseoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:STRING
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:STRING
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:STRING
HIGH…/src/airflow/serialization/definitions/baseoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:STRING
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:STRING
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:STRING
HIGH…/src/airflow/serialization/definitions/baseoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:STRING
HIGHtask-sdk/src/airflow/sdk/serde/__init__.py0return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster thanSTRING
HIGHtask-sdk/src/airflow/sdk/serde/typing.py0return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster thanSTRING
HIGHairflow-core/src/airflow/serialization/typing.py0return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster thanSTRING
HIGHproviders/ftp/src/airflow/providers/ftp/assets/ftp.py0translate asset with valid aip-60 uri to openlineage with assistance from the hook.STRING
511 more matches not shown…
Hallucination Indicators262 hits · 2710 pts
SeverityFileLineSnippetContext
CRITICALairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py257# This mirrors org.apache.spark.launcher.JavaModuleOptions.defaultModuleOptions()COMMENT
CRITICALairflow-ctl/src/airflowctl/ctl/cli_parser.py45from airflowctl.utils.helpers import partitionCODE
CRITICAL…tableau/src/airflow/providers/tableau/hooks/tableau.py25from airflow.utils.helpers import exactly_oneCODE
CRITICAL…unit/amazon/aws/triggers/test_opensearch_serverless.py29from airflow.utils.helpers import prune_dictCODE
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py71 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(CODE
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py101 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(CODE
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py140 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(CODE
CRITICAL…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py56from airflow.utils.helpers import convert_camel_to_snakeCODE
CRITICAL…unit/amazon/aws/executors/batch/test_batch_executor.py47from airflow.utils.helpers import convert_camel_to_snakeCODE
CRITICAL…ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py182 mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params)CODE
CRITICAL…ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py201 mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params)CODE
CRITICAL…oviders/amazon/tests/unit/amazon/aws/hooks/test_dms.py453 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.py100 from moto.core.exceptions import AWSErrorCODE
CRITICAL…rs/amazon/tests/unit/amazon/aws/hooks/test_base_aws.py446 user_agent_dict = dict(tag.split("/") for tag in executor.ecs.meta.config.user_agent.split(" "))CODE
CRITICAL…unit/amazon/aws/hooks/test_sagemaker_unified_studio.py113 self.hook._sagemaker_studio.execution_client.start_execution.assert_called_once()CODE
CRITICAL…unit/amazon/aws/hooks/test_sagemaker_unified_studio.py124 self.hook._sagemaker_studio.execution_client.get_execution.assert_called()CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py357 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py412 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py455 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py512 hook.resource.Object.return_value.load.assert_called_with(CODE
CRITICAL…/tests/unit/amazon/aws/auth_manager/avp/test_facade.py30from airflow.utils.helpers import prune_dictCODE
CRITICALproviders/amazon/tests/system/amazon/aws/utils/k8s.py19from airflow.utils.helpers import exactly_oneCODE
CRITICAL…/providers/amazon/aws/sensors/opensearch_serverless.py29from airflow.utils.helpers import exactly_oneCODE
CRITICAL…c/airflow/providers/amazon/aws/operators/s3_vectors.py27from airflow.utils.helpers import prune_dictCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/rds.py38from airflow.utils.helpers import prune_dictCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/emr.py66from airflow.utils.helpers import exactly_one, prune_dictCODE
CRITICAL…low/providers/amazon/aws/operators/redshift_cluster.py39from airflow.utils.helpers import prune_dictCODE
CRITICAL…airflow/providers/amazon/aws/operators/glue_catalog.py28from airflow.utils.helpers import prune_dictCODE
CRITICAL…/airflow/providers/amazon/aws/operators/eventbridge.py26from airflow.utils.helpers import prune_dictCODE
CRITICAL…flow/providers/amazon/aws/operators/mwaa_serverless.py28from airflow.utils.helpers import prune_dictCODE
CRITICAL…rc/airflow/providers/amazon/aws/operators/sagemaker.py50from airflow.utils.helpers import prune_dictCODE
CRITICAL…roviders/amazon/aws/operators/opensearch_serverless.py29from airflow.utils.helpers import prune_dictCODE
CRITICAL…rc/airflow/providers/amazon/aws/operators/s3_tables.py31from airflow.utils.helpers import prune_dictCODE
CRITICAL…mazon/src/airflow/providers/amazon/aws/operators/s3.py35from airflow.utils.helpers import exactly_oneCODE
CRITICAL…/src/airflow/providers/amazon/aws/operators/bedrock.py47from airflow.utils.helpers import prune_dictCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/ecs.py43from airflow.utils.helpers import prune_dictCODE
CRITICAL…providers/amazon/aws/triggers/opensearch_serverless.py23from airflow.utils.helpers import exactly_oneCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/triggers/base.py27from airflow.utils.helpers import prune_dictCODE
CRITICAL…zon/src/airflow/providers/amazon/aws/utils/__init__.py28from airflow.utils.helpers import prune_dictCODE
CRITICAL…rflow/providers/amazon/aws/transfers/dynamodb_to_s3.py36from airflow.utils.helpers import prune_dictCODE
CRITICAL…viders/amazon/aws/executors/ecs/ecs_executor_config.py46from airflow.utils.helpers import prune_dictCODE
CRITICAL…low/providers/amazon/aws/executors/ecs/ecs_executor.py53from airflow.utils.helpers import merge_dicts, prune_dictCODE
CRITICAL…providers/amazon/aws/executors/batch/batch_executor.py38from airflow.utils.helpers import merge_dicts, prune_dictCODE
CRITICAL…rs/amazon/aws/executors/batch/batch_executor_config.py42from airflow.utils.helpers import prune_dictCODE
CRITICAL…ers/amazon/aws/executors/aws_lambda/lambda_executor.py47from airflow.utils.helpers import prune_dictCODE
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/links/emr.py26from airflow.utils.helpers import exactly_oneCODE
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/hooks/sqs.py23from airflow.utils.helpers import prune_dictCODE
CRITICAL…/src/airflow/providers/amazon/aws/hooks/eventbridge.py22from airflow.utils.helpers import prune_dictCODE
CRITICAL…/amazon/src/airflow/providers/amazon/aws/hooks/logs.py27from airflow.utils.helpers import prune_dictCODE
CRITICAL…zon/src/airflow/providers/amazon/aws/hooks/base_aws.py60from airflow.utils.helpers import exactly_oneCODE
CRITICAL…rs/amazon/src/airflow/providers/amazon/aws/hooks/s3.py66from airflow.utils.helpers import chunksCODE
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/hooks/sns.py25from airflow.utils.helpers import prune_dictCODE
CRITICAL…irflow/providers/amazon/aws/auth_manager/avp/facade.py34from airflow.utils.helpers import prune_dictCODE
CRITICAL…/src/airflow/providers/amazon/aws/notifications/ses.py26from airflow.utils.helpers import prune_dictCODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py189 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py253 mock_client.secrets.kv.v2.read_secret_version.assert_not_called()CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py347 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py442 mock_client.secrets.kv.v1.read_secret.assert_called_once_with(**expected_args)CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py472 mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with(CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py781 mock_client.secrets.kv.v2.read_secret_version.assert_called_once_with(CODE
202 more matches not shown…
Decorative Section Separators622 hits · 2092 pts
SeverityFileLineSnippetContext
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py64# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py66# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py170# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py172# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py226# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py228# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py249# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py251# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py268# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py270# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py336# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py338# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py41# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py43# ---------------------------------------------------------------------------COMMENT
MEDIUM…low/providers/amazon/aws/executors/ecs/ecs_executor.py682 # ── Back-compat shims for renamed methods/attrs ────────────────────────COMMENT
MEDIUM…ders/google/tests/unit/google/cloud/links/test_base.py24# ---------------------------------------------------------------------------COMMENT
MEDIUM…ders/google/tests/unit/google/cloud/links/test_base.py26# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1956 # -------------------------------------------------------------------------COMMENT
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1958 # -------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py24# --------------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py26# --------------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py34# --------------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py37# --------------------------------------------------------------------------------COMMENT
MEDIUM…azure/tests/unit/microsoft/azure/hooks/test_compute.py206 # ------------------------------------------------------------------COMMENT
MEDIUM…azure/tests/unit/microsoft/azure/hooks/test_compute.py208 # ------------------------------------------------------------------COMMENT
MEDIUM…src/airflow/providers/microsoft/azure/hooks/compute.py172 # ------------------------------------------------------------------COMMENT
MEDIUM…src/airflow/providers/microsoft/azure/hooks/compute.py174 # ------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py45# ----------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py47# ----------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py72# ----------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py74# ----------------------------------------------------------------------COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py149 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py151 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py153 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py155 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py163 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py165 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py169 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py171 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py173 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py175 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py186 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py188 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py198 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py200 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py204 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py206 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py208 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py210 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py212 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py214 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py218 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py220 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py224 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py226 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py229 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py231 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py236 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py238 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py240 # ============================================================================COMMENT
562 more matches not shown…
Excessive Try-Catch Wrapping1125 hits · 1186 pts
SeverityFileLineSnippetContext
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py668 except Exception:CODE
LOW…ject_storage_tests/test_xcom_object_storage_backend.py65 except Exception as e:CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py163 except Exception:CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py198 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py85 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py119 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py183 except Exception as e:CODE
LOW…-ctl/src/airflowctl/ctl/commands/connection_command.py46 except Exception as e:CODE
LOW…-ctl/src/airflowctl/ctl/commands/connection_command.py73 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/pool_command.py82 except Exception as e:CODE
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py833 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py251 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py258 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py288 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py340 except Exception:CODE
LOW…_sdk/execution_time/test_connection_test_supervisor.py244 except Exception as e:CODE
MEDIUM…_sdk/execution_time/test_connection_test_supervisor.py241def capture():CODE
LOW…k-sdk/tests/task_sdk/execution_time/test_supervisor.py1342 except Exception as e:CODE
LOWtask-sdk/tests/task_sdk/execution_time/test_comms.py165 except Exception as e:CODE
MEDIUMtask-sdk/tests/task_sdk/execution_time/test_comms.py161def send_and_store(idx):CODE
LOWtask-sdk/src/airflow/sdk/configuration.py159 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/log.py236 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py106 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py593 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/plugins_manager.py94 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/lineage.py203 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/timezone.py38except Exception:CODE
LOWtask-sdk/src/airflow/sdk/io/path.py161 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/bases/sensor.py220 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/bases/notifier.py139 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/bases/notifier.py153 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/comms.py366 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py303 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py394 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py471 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py483 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py920 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py954 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1199 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1391 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1519 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1538 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1643 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2337 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2489 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2242 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2252 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2260 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2268 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2278 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2285 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1190 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1418 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1430 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1579 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1691 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1780 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1990 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2064 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2229 except Exception:CODE
1065 more matches not shown…
Self-Referential Comments282 hits · 856 pts
SeverityFileLineSnippetContext
MEDIUMclients/python/test_python_client.py108 # 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.py107# 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.py118# Define an asset that watches for messages on the queueCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py119 # Create a mock KubernetesExecutor instanceCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py136 # Create a test task keyCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py179 # Create a mock KubernetesExecutor instanceCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py183 # Create a test task keyCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py215 # Create a mock KubernetesExecutor instanceCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py220 # Create a test task keyCOMMENT
MEDIUMairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py231 # Create a temporary fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py146 # Create a proper pool object with dictionary attributes instead of MagicMockCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py159 # Create a mock response with proper dictionary attributesCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py341 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py358 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py375 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py394 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py411 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py428 # Create a corrupted config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py442 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py293 # Create a config fileCOMMENT
MEDIUMtask-sdk/tests/task_sdk/test_lineage.py722 # Create a large valueCOMMENT
MEDIUMtask-sdk/tests/task_sdk/test_lineage.py778 # Create a non-serializable objectCOMMENT
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py836 # Create a directory that existsCOMMENT
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py840 # Create a mock bundle instanceCOMMENT
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py858 # Create a directory with read permissionsCOMMENT
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py778 # Create a mock client to assert calls to the clientCOMMENT
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py1233 # Create a fake placeholder in the open socket weakrefCOMMENT
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py3496 # Create a simple TaskInstance datamodel to pass to the supervisorCOMMENT
MEDIUMtask-sdk/tests/task_sdk/definitions/test_dag.py336 # Create a linear chain: t1 -> t2 -> t3 -> t4 -> t5COMMENT
MEDIUMtask-sdk/tests/task_sdk/definitions/test_dag.py371 # Create a diamond pattern:COMMENT
MEDIUM…-sdk/tests/task_sdk/definitions/test_mappedoperator.py810 # Create a mapped task within the task groupCOMMENT
MEDIUMtask-sdk/dev/datamodel_code_formatter.py109 # Create a replacement for 'Tasks' -> 'tuple[str, int]'COMMENT
MEDIUMtask-sdk/src/airflow/sdk/execution_time/supervisor.py2090 # Create a socketpair preemptively, in case the task process runs VirtualEnv operator or run_as_userCOMMENT
MEDIUMtask-sdk/src/airflow/sdk/execution_time/supervisor.py2143 # Create a minimal supervisor instance for trigger executionCOMMENT
MEDIUM…sdk/src/airflow/sdk/execution_time/execute_workload.py66 # Create a mutually exclusive group to ensure that only one of the flags is setCOMMENT
MEDIUMtask-sdk/src/airflow/sdk/api/client.py309 # Create a deferred state payload from msgCOMMENT
MEDIUMtask-sdk/src/airflow/sdk/api/client.py321 # Create a reschedule state payload from msgCOMMENT
MEDIUMproviders-summary-docs/conf.py26# This file is execfile()d with the current directory set to itsCOMMENT
MEDIUM…ders/presto/tests/unit/presto/hooks/test_presto_sql.py149 # Create a real Airflow connectionCOMMENT
MEDIUM…it/amazon/aws/sensors/test_sagemaker_unified_studio.py91 # Create the sensorCOMMENT
MEDIUM…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1034 # Create a temporary credentials fileCOMMENT
MEDIUM…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1093 # Create a temporary credentials fileCOMMENT
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py141 # Create the operatorCOMMENT
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py189 # Create the operator with wait_for_completion set to TrueCOMMENT
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py239 # Create the operator with wait_for_completion set to FalseCOMMENT
MEDIUM…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py173 # Create a test file remotelyCOMMENT
MEDIUM…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py183 # Create a new Collection and verify it is empty.COMMENT
MEDIUM…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py275 # Create a new Collection and add a two tasks.COMMENT
MEDIUM…mazon/aws/executors/aws_lambda/test_lambda_executor.py1211 # Create a team-specific executor.COMMENT
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py107 # Create the local log file structureCOMMENT
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py154 # Create a logger factory and pass in the file path we want it to useCOMMENT
MEDIUM…viders/amazon/tests/unit/amazon/aws/bundles/test_s3.py195 # Create a pytest Call object to compare against the call_args_list of the _log.debug mockCOMMENT
MEDIUM…ders/amazon/tests/system/amazon/aws/example_bedrock.py65# Creating a custom model takes nearly two hours. If SKIP_LONG_TASKSCOMMENT
MEDIUM…tests/system/amazon/aws/example_eks_with_nodegroups.py94 # Create an Amazon EKS Cluster control plane without attaching compute service.COMMENT
MEDIUM…ers/amazon/tests/system/amazon/aws/example_datasync.py184 # Create a task (the task does not exist)COMMENT
MEDIUM…/system/amazon/aws/example_eks_with_fargate_profile.py78 # Create an Amazon EKS Cluster control plane without attaching a compute service.COMMENT
MEDIUM…m/amazon/aws/example_eks_with_nodegroup_in_one_step.py92 # Create an Amazon EKS cluster control plane and an EKS nodegroup compute platform in one step.COMMENT
MEDIUMproviders/amazon/tests/system/amazon/aws/example_ec2.py62 # Creating the key takes a very short but measurable time, preventing race condition:COMMENT
MEDIUM…azon/tests/system/amazon/aws/example_dms_serverless.py118 # Create the Table.COMMENT
MEDIUM…azon/tests/system/amazon/aws/example_step_functions.py57 # Create a Step Functions State Machine and return the ARN for use byCOMMENT
222 more matches not shown…
Deep Nesting939 hits · 809 pts
SeverityFileLineSnippetContext
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py586CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py245CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py217CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py608CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py789CODE
LOWairflow-ctl/src/airflowctl/api/client.py199CODE
LOWairflow-ctl/src/airflowctl/api/client.py250CODE
LOWairflow-ctl/src/airflowctl/api/operations.py167CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py858CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py430CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py624CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py703CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py707CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py124CODE
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py729CODE
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py105CODE
LOWtask-sdk/tests/conftest.py178CODE
LOW…k-sdk/tests/task_sdk/test_providers_manager_runtime.py182CODE
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py5663CODE
LOW…k-sdk/tests/task_sdk/execution_time/test_supervisor.py3552CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py218CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py567CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py993CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py1006CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py1010CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py441CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py496CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py610CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py463CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py515CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py650CODE
LOWtask-sdk/src/airflow/sdk/configuration.py211CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py251CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py305CODE
LOWtask-sdk/src/airflow/sdk/coordinators/_subprocess.py70CODE
LOWtask-sdk/src/airflow/sdk/coordinators/_subprocess.py157CODE
LOWtask-sdk/src/airflow/sdk/io/fs.py52CODE
LOWtask-sdk/src/airflow/sdk/bases/sensor.py183CODE
LOWtask-sdk/src/airflow/sdk/bases/resumablejobmixin.py103CODE
LOWtask-sdk/src/airflow/sdk/bases/decorator.py279CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py2005CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py680CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1010CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1131CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1469CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1689CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py957CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1362CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1375CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1513CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2210CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2305CODE
LOW…/src/airflow/sdk/execution_time/callback_supervisor.py349CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py320CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py1369CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py852CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py1218CODE
LOW…-sdk/src/airflow/sdk/execution_time/schema/__init__.py73CODE
LOWtask-sdk/src/airflow/sdk/definitions/mappedoperator.py117CODE
LOWtask-sdk/src/airflow/sdk/definitions/xcom_arg.py100CODE
879 more matches not shown…
Cross-Language Confusion132 hits · 768 pts
SeverityFileLineSnippetContext
HIGH…tests/kubernetes_tests/test_kubernetes_pod_operator.py546 'echo "retrieved from mount" > /tmp/test_volume/test.txt && cat /tmp/test_volume/test.txt'CODE
HIGHtask-sdk/tests/task_sdk/api/test_client.py772 # Return None (null) when no previous TI foundCOMMENT
HIGHtask-sdk/tests/task_sdk/api/test_client.py1602 # Return None (null) when no previous Dag run foundCOMMENT
HIGHtask-sdk/tests/task_sdk/serde/test_serializers.py282 assert i.equals(d)CODE
HIGHtask-sdk/src/airflow/sdk/bases/operator.py1533 DagContext.push(None)CODE
HIGHtask-sdk/src/airflow/sdk/definitions/dag.py751 DagContext.push(self)CODE
HIGHtask-sdk/src/airflow/sdk/definitions/taskgroup.py393 TaskGroupContext.push(self)CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py139 assert read_df.equals(test_df)CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py238 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py248 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py290 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py332 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py342 assert df.equals(CODE
HIGH…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py500 '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}',STRING
HIGH…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py510 '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}',STRING
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py59 if command -v yum &> /dev/null; thenCODE
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py61 elif command -v dnf &> /dev/null; thenCODE
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py69 if ! command -v amazon-ssm-agent &> /dev/null; thenCODE
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py40 backend_kwargs = {"connections_prefix": "/airflow/connections", "profile_name": null}STRING
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py48 If set to None (null), requests for connections will not be sent to AWS SSM Parameter Store.STRING
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py54 If set to None (null), requests for variables will not be sent to AWS SSM Parameter Store.STRING
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py60 If set to None (null), requests for configurations will not be sent to AWS SSM Parameter Store.STRING
HIGH…mazon/src/airflow/providers/amazon/aws/hooks/athena.py258 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.py94 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py52 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py66 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py80 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…data/src/airflow/providers/teradata/utils/bteq_util.py32 stdin, stdout, stderr = ssh_client.exec_command("uname || ver")CODE
HIGH…adata/src/airflow/providers/teradata/utils/tpt_util.py132 f"dd if=/dev/zero of={file_path} bs=4096 count=$(($(stat -c '%s' {file_path})/4096+1)) 2>/dev/nuCODE
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py51 (default: 'connections'). If set to None (null), requests for connections will not be sent to Vault.STRING
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py53 (default: 'variables'). If set to None (null), requests for variables will not be sent to Vault.STRING
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py55 (default: 'config'). If set to None (null), requests for configurations will not be sent to Vault.STRING
HIGH…ts/unit/google/cloud/transfers/test_postgres_to_gcs.py44 b'{"some_json": {"firtname": "John", "lastname": "Smith", "nested_dict": {"a": null, "b": "something"}}, "some_num":CODE
HIGH…ts/unit/google/cloud/transfers/test_postgres_to_gcs.py73 "nested_dict": {"a": null, "b": "something"}}',CODE
HIGH…tests/unit/google/cloud/transfers/test_mssql_to_gcs.py298 assert schema.field("some_binary").type.equals(pyarrow.bool_())CODE
HIGH…tests/unit/google/cloud/transfers/test_mssql_to_gcs.py299 assert schema.field("some_bit").type.equals(pyarrow.bool_())CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py398 assert df.equals(OUTPUT_DF)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py420 assert df.equals(OUTPUT_DF)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py442 assert df.equals(OUTPUT_DF)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py472 assert df.equals(output_df)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py501 assert df.equals(OUTPUT_DF_WITH_EXCLUDE_COLUMNS)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py529 assert concat_df.equals(OUTPUT_DF)CODE
HIGH…system/google/cloud/cloud_build/example_cloud_build.py69 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}],CODE
HIGH…system/google/cloud/cloud_build/example_cloud_build.py76 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}],CODE
HIGH…system/google/cloud/cloud_build/example_cloud_build.py82 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 300"]}],CODE
HIGH…oogle/tests/system/google/cloud/ray/example_ray_job.py93 entrypoint="echo hi && sleep 105 && echo hi2",CODE
HIGH…s/google/src/airflow/providers/google/ads/hooks/ads.py57 "json_key_file_path": null,STRING
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py64 If set to None (null), requests for connections will not be sent to GCP Secrets ManagerSTRING
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py66 If set to None (null), requests for variables will not be sent to GCP Secrets ManagerSTRING
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py69 If set to None (null), requests for configurations will not be sent to GCP Secrets ManagerSTRING
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py71 If set to None (null), requests for connections will not be sent to Azure Key VaultSTRING
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py73 If set to None (null), requests for variables will not be sent to Azure Key VaultSTRING
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py75 If set to None (null), requests for configurations will not be sent to Azure Key VaultSTRING
HIGH…s/standard/tests/unit/standard/decorators/test_bash.py152 assert bash_task.operator.bash_command == "echo hello world && echo 2"CODE
HIGH…s/standard/tests/unit/standard/decorators/test_bash.py155 self.validate_bash_command_rtif(ti, "echo hello world && echo 2")CODE
HIGH…/sql/src/airflow/providers/common/sql/operators/sql.py1606 self.push(meta_data)CODE
HIGHproviders/ssh/tests/unit/ssh/utils/test_remote_job.py355 subprocess.run(["bash", "-c", f"kill -9 -{pgid} 2>/dev/null || true"], check=False)CODE
HIGHproviders/ssh/tests/unit/ssh/utils/test_remote_job.py356 subprocess.run(["bash", "-c", f"pkill -9 -f '{marker}' 2>/dev/null || true"], check=False)CODE
HIGH…ders/ssh/src/airflow/providers/ssh/utils/remote_job.py353 return f"stat -c%s '{file_path}' 2>/dev/null || stat -f%z '{file_path}' 2>/dev/null || echo 0"CODE
HIGH…ders/ssh/src/airflow/providers/ssh/utils/remote_job.py425 f'if [ "$p" -gt 1 ] 2>/dev/null; then 'CODE
72 more matches not shown…
AI Structural Patterns703 hits · 658 pts
SeverityFileLineSnippetContext
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py216CODE
LOWairflow-ctl/src/airflowctl/api/operations.py627CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py131CODE
LOWtask-sdk/tests/conftest.py220CODE
LOWtask-sdk/tests/conftest.py240CODE
LOWtask-sdk/tests/conftest.py263CODE
LOWtask-sdk/tests/conftest.py306CODE
LOW…s/task_sdk/coordinators/executable/test_coordinator.py67CODE
LOWtask-sdk/dev/datamodel_code_formatter.py144CODE
LOWtask-sdk/src/airflow/sdk/io/path.py61CODE
LOWtask-sdk/src/airflow/sdk/bases/sensor.py115CODE
LOWtask-sdk/src/airflow/sdk/bases/decorator.py441CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py277CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py1029CODE
LOWtask-sdk/src/airflow/sdk/api/client.py852CODE
LOWtask-sdk/src/airflow/sdk/definitions/dag.py1606CODE
LOWtask-sdk/src/airflow/sdk/definitions/connection.py130CODE
LOW…k/src/airflow/sdk/definitions/decorators/task_group.py194CODE
LOW…src/airflow/providers/papermill/operators/papermill.py75CODE
LOW…ocker/src/airflow/providers/docker/operators/docker.py227CODE
LOW…src/airflow/providers/docker/operators/docker_swarm.py126CODE
LOW…src/airflow/providers/discord/hooks/discord_webhook.py186CODE
LOW…src/airflow/providers/discord/hooks/discord_webhook.py287CODE
LOW…eau/src/airflow/providers/tableau/operators/tableau.py87CODE
LOW…amazon/src/airflow/providers/amazon/aws/sensors/sqs.py95CODE
LOW…amazon/src/airflow/providers/amazon/aws/sensors/sqs.py183CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/rds.py187CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/dms.py179CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/dms.py772CODE
LOW…iders/amazon/aws/operators/sagemaker_unified_studio.py115CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/ses.py82CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py121CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py265CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py518CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py728CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py1271CODE
LOW…low/providers/amazon/aws/operators/redshift_cluster.py159CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/eks.py80CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/eks.py270CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/eks.py522CODE
LOW…on/src/airflow/providers/amazon/aws/operators/batch.py149CODE
LOW…ow/providers/amazon/aws/operators/neptune_analytics.py101CODE
LOW…ow/providers/amazon/aws/operators/neptune_analytics.py604CODE
LOW…ow/providers/amazon/aws/operators/neptune_analytics.py839CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/mwaa.py89CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/glue.py127CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/glue.py522CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/glue.py684CODE
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py281CODE
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py782CODE
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py1212CODE
LOW…zon/aws/operators/sagemaker_unified_studio_notebook.py108CODE
LOW…src/airflow/providers/amazon/aws/operators/datasync.py136CODE
LOW…n/src/airflow/providers/amazon/aws/operators/athena.py87CODE
LOW…mazon/src/airflow/providers/amazon/aws/operators/s3.py823CODE
LOW…irflow/providers/amazon/aws/operators/redshift_data.py117CODE
LOW…flow/providers/amazon/aws/operators/lambda_function.py77CODE
LOW…/src/airflow/providers/amazon/aws/operators/bedrock.py712CODE
LOW…/src/airflow/providers/amazon/aws/operators/bedrock.py1366CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/ecs.py437CODE
643 more matches not shown…
Modern Structural Boilerplate426 hits · 425 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/src/airflowctl/api/client.py83__all__ = [CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/__init__.py24__all__ = ["console"]CODE
LOWtask-sdk/src/airflow/sdk/__init__.py21__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/types.py28__all__ = ["TaskInstance", "TaskInstanceKey"]CODE
LOWtask-sdk/src/airflow/sdk/timezone.py41__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/listener.py45__all__ = ["get_listener_manager", "ListenerManager"]CODE
LOW…dk/src/airflow/sdk/coordinators/executable/__init__.py23__all__ = ["ExecutableCoordinator", "__version__"]CODE
LOWtask-sdk/src/airflow/sdk/coordinators/java/__init__.py27__all__ = ["JavaCoordinator"]CODE
LOWtask-sdk/src/airflow/sdk/coordinators/node/__init__.py28__all__ = ["NodeCoordinator"]CODE
LOWtask-sdk/src/airflow/sdk/io/__init__.py25__all__ = ["ObjectStoragePath", "attach", "get_fs", "has_fs", "Properties"]CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py106__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py1433 def _set_xcomargs_dependencies(self) -> None:CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py1441 def _set_xcomargs_dependency(self, field: str, newvalue: Any) -> None:CODE
LOWtask-sdk/src/airflow/sdk/observability/__init__.py21__all__ = ["trace"]CODE
LOWtask-sdk/src/airflow/sdk/observability/stats.py33__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/execution_time/coordinator.py64__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py178__all__ = ["ActivitySubprocess", "WatchedSubprocess", "supervise", "supervise_task"]CODE
LOW…/src/airflow/sdk/execution_time/callback_supervisor.py73__all__ = ["CallbackSubprocess", "supervise_callback"]CODE
LOW…rflow/sdk/execution_time/connection_test_supervisor.py35__all__ = ["supervise_connection_test"]CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py395def _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__.py24__all__ = ["ExecutionAPISecretsBackend", "DEFAULT_SECRETS_SEARCH_PATH_WORKERS"]CODE
LOW…-sdk/src/airflow/sdk/execution_time/schema/__init__.py133__all__ = [CODE
LOW…-sdk/src/airflow/sdk/execution_time/schema/migrator.py220__all__ = ["SchemaVersionMigrator", "get_schema_version_migrator"]CODE
LOW…-sdk/src/airflow/sdk/execution_time/sentry/__init__.py23__all__ = ["Sentry"]CODE
LOWtask-sdk/src/airflow/sdk/api/client.py183__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/dag.py89__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/param.py35logger = logging.getLogger(__name__)CODE
LOWtask-sdk/src/airflow/sdk/definitions/retry_policy.py39__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/deadline.py35logger = logging.getLogger(__name__)CODE
LOW…rc/airflow/sdk/definitions/_internal/contextmanager.py33__all__ = ["DagContext", "TaskGroupContext"]CODE
LOWtask-sdk/src/airflow/sdk/definitions/_internal/types.py29__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/asset/metadata.py29__all__ = ["Metadata"]CODE
LOWtask-sdk/src/airflow/sdk/definitions/asset/__init__.py49__all__ = [CODE
LOW…sdk/src/airflow/sdk/definitions/decorators/__init__.py35__all__ = [CODE
LOW…dk/src/airflow/sdk/definitions/decorators/condition.py36__all__ = ["run_if", "skip_if"]CODE
LOW…rs/neo4j/src/airflow/providers/neo4j/version_compat.py37__all__ = [CODE
LOWproviders/neo4j/src/airflow/providers/neo4j/__init__.py30__all__ = ["__version__"]CODE
LOW…/cohere/src/airflow/providers/cohere/version_compat.py33__all__ = [CODE
LOW…viders/cohere/src/airflow/providers/cohere/__init__.py30__all__ = ["__version__"]CODE
LOW…rs/cohere/src/airflow/providers/cohere/hooks/cohere.py35logger = logging.getLogger(__name__)CODE
LOW…viders/ftp/src/airflow/providers/ftp/version_compat.py38__all__ = ["AIRFLOW_V_3_0_PLUS", "AIRFLOW_V_3_1_PLUS"]CODE
LOWproviders/ftp/src/airflow/providers/ftp/__init__.py30__all__ = ["__version__"]CODE
LOWproviders/ftp/src/airflow/providers/ftp/hooks/ftp.py28logger = logging.getLogger(__name__)CODE
LOW…/presto/src/airflow/providers/presto/version_compat.py37__all__ = [CODE
LOW…viders/presto/src/airflow/providers/presto/__init__.py30__all__ = ["__version__"]CODE
LOW…mill/src/airflow/providers/papermill/version_compat.py33__all__ = [CODE
LOW…/papermill/src/airflow/providers/papermill/__init__.py30__all__ = ["__version__"]CODE
LOW…/docker/src/airflow/providers/docker/version_compat.py48__all__ = [CODE
LOW…viders/docker/src/airflow/providers/docker/__init__.py30__all__ = ["__version__"]CODE
LOW…ders/imap/src/airflow/providers/imap/version_compat.py38__all__ = [CODE
LOWproviders/imap/src/airflow/providers/imap/__init__.py30__all__ = ["__version__"]CODE
LOW…iscord/src/airflow/providers/discord/version_compat.py39__all__ = [CODE
LOW…ders/discord/src/airflow/providers/discord/__init__.py30__all__ = ["__version__"]CODE
LOW…ableau/src/airflow/providers/tableau/version_compat.py38__all__ = ["AIRFLOW_V_3_0_PLUS", "AIRFLOW_V_3_1_PLUS"]CODE
LOW…ders/tableau/src/airflow/providers/tableau/__init__.py30__all__ = ["__version__"]CODE
LOW…rs/amazon/tests/system/amazon/aws/example_sagemaker.py71logger = logging.getLogger(__name__)CODE
LOW…/amazon/src/airflow/providers/amazon/version_compat.py57__all__ = [CODE
LOW…viders/amazon/src/airflow/providers/amazon/__init__.py30__all__ = ["__version__"]CODE
LOW…amazon/src/airflow/providers/amazon/aws/sensors/rds.py200__all__ = [CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/rds.py980__all__ = [CODE
366 more matches not shown…
Redundant / Tautological Comments221 hits · 326 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py129 # Check if directory existsCOMMENT
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py201 # Display resultsCOMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py1976 # Assign task to DagCOMMENT
LOWtask-sdk/dev/datamodel_code_formatter.py102 # Check if the target is 'tasks'COMMENT
LOWtask-sdk/src/airflow/sdk/configuration.py315 # Check if the secrets_backend_list contains only 2 default backends.COMMENT
LOWtask-sdk/src/airflow/sdk/configuration.py317 # Check if we are loading the backends for worker too by checking if the default_backends is equalCOMMENT
LOWtask-sdk/src/airflow/sdk/bases/decorator.py223 # Check if args conflict with names in kwargs.COMMENT
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1128 # Check if the subprocess has exitedCOMMENT
LOWtask-sdk/src/airflow/sdk/definitions/taskgroup.py377 # Check if the current TaskGroup is emptyCOMMENT
LOW…/airflow/sdk/definitions/_internal/abstractoperator.py240 # Check if the operator has an explicit native rendering preferenceCOMMENT
LOWtask-sdk/src/airflow/sdk/serde/typing.py32 # Check if it is not a dataclass to prevent detecting pydantic dataclasses as pydantic modelsCOMMENT
LOW…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1141 # Set status to None so define_container_state returns UNDEFINED (not terminal)COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py90 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py163 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py221 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py279 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py114 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py205 # Check if object was created in s3COMMENT
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py172 # Check if a file existsSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py181 # Check if both files existSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py190 # Check if a file existsSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py200 # Check if both files existSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py210 # Check if a file exists and match a certain pattern defined in check_fnSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py221 # Check if a file exists and match a certain regular expression patternSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py232 # Check if a file exists and match a certain pattern defined in check_fnSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py242 # Check if a file exists and match a certain regular expression patternSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_emr.py92 # Set KeepJobFlowAliveWhenNoSteps to False to avoid the cluster from being torn down prematurely.COMMENT
LOW…amazon/src/airflow/providers/amazon/aws/sensors/ssm.py118 # Check if we should tolerate this failureCOMMENT
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py347 # 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.py875 # 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.py1276 # 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.py99 # Read the file content in chunks using StreamingBodyCOMMENT
LOW…low/providers/amazon/aws/executors/ecs/ecs_executor.py120 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the globalCOMMENT
LOW…providers/amazon/aws/executors/batch/batch_executor.py110 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the globalCOMMENT
LOW…ers/amazon/aws/executors/aws_lambda/lambda_executor.py89 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the globalCOMMENT
LOW…zon/src/airflow/providers/amazon/aws/hooks/base_aws.py581 # Check if we can find an executorCOMMENT
LOW…ers/teradata/tests/unit/teradata/operators/test_tpt.py292 # Set hook to NoneCOMMENT
LOW…ers/teradata/tests/unit/teradata/operators/test_tpt.py708 # Set hooks to NoneCOMMENT
LOW…rs/teradata/tests/unit/teradata/utils/test_tpt_util.py540 # Check if permissions were set correctlyCOMMENT
LOW…adata/src/airflow/providers/teradata/operators/bteq.py43 # Check if the parameter contains Jinja templating syntaxCOMMENT
LOW…data/src/airflow/providers/teradata/utils/bteq_util.py50 # Check if zsh exists firstCOMMENT
LOW…adata/src/airflow/providers/teradata/utils/tpt_util.py77 # Check if shred is availableCOMMENT
LOW…adata/src/airflow/providers/teradata/utils/tpt_util.py110 # Check if shred is available on remote system (UNIX/Linux)COMMENT
LOW…dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py62 # Check if ``account_id`` was not included in the function signature or, if it is, the value is notCOMMENT
LOW…dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py843 # Check if the job-run duration has exceeded the ``timeout`` configured.COMMENT
LOW…irflow/providers/edge3/plugins/edge_executor_plugin.py56# Check if EdgeExecutor is actually loadedCOMMENT
LOW…src/airflow/providers/edge3/executors/edge_executor.py63 # 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.py139 # Check if job already exists with same dag_id, task_id, run_id, map_index, try_numberCOMMENT
LOW…e3/src/airflow/providers/edge3/worker_api/routes/ui.py290 # Check if worker exists firstCOMMENT
LOW…/providers/google/common/utils/id_token_credentials.py151 # Check if application default credentials exist.COMMENT
LOW…viders/google/cloud/sensors/vertex_ai/feature_store.py85 # Check if the sync has completed by verifying end_time existsCOMMENT
LOW…c/airflow/providers/google/cloud/operators/dataproc.py983 # Check if cluster is not in ERROR state.COMMENT
LOW…airflow/providers/google/cloud/transfers/gcs_to_gcs.py295 # Check if prefix contains wildcardCOMMENT
LOW…e/src/airflow/providers/google/cloud/hooks/bigquery.py317 # Check if tableReference is present and is validCOMMENT
LOW…e/src/airflow/providers/google/cloud/hooks/bigquery.py324 # Check if value is already present if no use the provided oneCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py403 # Verify if the output table id from the parse result matches the BQ job output tableCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py412 # Verify if all columns from parse results are present in the output dataset schemaCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py421 # Verify if all datasets from parse results are present in bq job input datasetsCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py425 # Verify if all columns from parse results are present in their respective bq job input datasetsCOMMENT
LOW…rc/airflow/providers/google/cloud/openlineage/utils.py133 # Check if the `InputField` class supports the `transformations` attribute (since OL client 1.17.1)COMMENT
161 more matches not shown…
Fake / Example Data256 hits · 262 pts
SeverityFileLineSnippetContext
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py3391 secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore eCODE
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py3391 secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore eCODE
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py237 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"CODE
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py252 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"CODE
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py268 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"CODE
LOWproviders/docker/provider.yaml146 extra: '{"reauth": false, "email": "Jane.Doe@example.org"}'CODE
LOW…cker/src/airflow/providers/docker/get_provider_info.py69 "placeholders": {"extra": '{"reauth": false, "email": "Jane.Doe@example.org"}'},CODE
LOW…rs/docker/src/airflow/providers/docker/hooks/docker.py229 "email": "Jane.Doe@example.org",CODE
LOW…/tests/unit/amazon/aws/auth_manager/avp/test_facade.py92 "dummy_id",CODE
LOW…/tests/unit/amazon/aws/auth_manager/avp/test_facade.py131 "dummy_id",CODE
LOW…/teradata/tests/system/teradata/example_remote_bteq.py87 INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT');CODE
LOWproviders/teradata/tests/system/teradata/script.sql26INSERT INTO {{params.TABLE_NAME}} VALUES (1, 'John Doe', 'IT');CODE
LOW…oviders/teradata/tests/system/teradata/example_bteq.py87 INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT');CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py45 "from": {"email": "foo@bar.com"},CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py58 "email": "foo@bar.com",CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py68 @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com")CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py100 @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com", SENDGRID_MAIL_SENDER="Foo")CODE
LOW…/edge3/tests/unit/edge3/worker_api/routes/test_logs.py62 log_chunk_data="This is Lorem Ipsum log data", log_chunk_time=timezone.utcnow()CODE
LOW…/edge3/tests/unit/edge3/worker_api/routes/test_logs.py81 assert "Lorem Ipsum" in logs[0].log_chunk_dataCODE
LOWproviders/trino/tests/unit/trino/hooks/test_trino.py580 {"login": "user@example.com", "password": "p@ss:word", "host": "localhost", "schema": "hive"},CODE
LOW…ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py73 return_value="test-example@example.org"CODE
LOW…ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py98 user="test-example@example.org",CODE
LOW…ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py145 return_value="test-example@example.org"CODE
LOW…/system/google/cloud/dataflow/example_dataflow_yaml.py83 "('John Doe', 900, 'USA'), "CODE
LOW…ts/unit/cncf/kubernetes/cli/test_kubernetes_command.py265 pods.metadata._continue = "dummy-token"CODE
LOW…ts/unit/cncf/kubernetes/cli/test_kubernetes_command.py280 _continue="dummy-token",CODE
LOW…ers/pgvector/tests/system/pgvector/example_pgvector.py62 f"VALUES ('John Doe', 123, '[1.0, 2.0, 3.0]')",CODE
LOW…ector/tests/system/pgvector/example_pgvector_openai.py75 f"VALUES ('John Doe', '123' ,'{embedd_query.output}')",CODE
LOW…cks/tests/unit/databricks/operators/test_databricks.py173 "name": "John Doe",CODE
LOWproviders/fab/tests/unit/fab/auth_manager/test_utils.py54 email=email or f"{username}@example.org",CODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py33 dummy_token = LoginResponse(access_token="DUMMY_TOKEN")CODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py38 mock_fab_auth_manager_login.create_token.return_value = self.dummy_tokenCODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py46 assert response.json()["access_token"] == self.dummy_token.access_tokenCODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py59 assert response.json()["access_token"] == self.dummy_token.access_tokenCODE
LOW…it/fab/auth_manager/api_fastapi/services/test_login.py46 self.dummy_token = "DUMMY_TOKEN"CODE
LOW…it/fab/auth_manager/api_fastapi/services/test_login.py50 auth_manager.generate_jwt.return_value = self.dummy_tokenCODE
LOW…it/fab/auth_manager/api_fastapi/services/test_login.py58 assert result.access_token == self.dummy_tokenCODE
LOW…viders/fab/src/airflow/providers/fab/cli/definition.py164 " --email admin@example.org"CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1553 assert token == "dummy_token"CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1568 json=lambda: {"access_token": "dummy_token", "expires_in": 600},CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1531 json=lambda: {"access_token": "dummy_token", "expires_in": 600},CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1585 assert token == "dummy_token"CODE
LOWproviders/jdbc/tests/unit/jdbc/hooks/test_jdbc.py283 "placeholder": "?",CODE
LOW…mmon/ai/tests/unit/common/ai/operators/test_llm_sql.py680 prompt="placeholder",CODE
LOW…common/ai/tests/unit/common/ai/operators/test_agent.py648 prompt="placeholder",CODE
LOW…s/common/ai/tests/unit/common/ai/operators/test_llm.py398 prompt="placeholder",CODE
LOW…/common/sql/datafusion/test_object_storage_provider.py38 credentials={"access_key_id": "fake_key", "secret_access_key": "fake_secret"},CODE
LOW…/common/sql/datafusion/test_object_storage_provider.py44 access_key_id="fake_key", secret_access_key="fake_secret", bucket_name="demo-data"CODE
LOW…ers/common/sql/tests/unit/common/sql/hooks/test_sql.py254 dbapi_hook = mock_db_hook(DbApiHook, conn_params={"extra": {"placeholder": "?"}})CODE
LOW…ers/common/sql/tests/unit/common/sql/hooks/test_sql.py260 dbapi_hook = mock_db_hook(DbApiHook, conn_params={"extra": {"placeholder": "!"}})CODE
LOW…s/common/sql/tests/unit/common/sql/hooks/test_dbapi.py504 extra=json.dumps({"placeholder": "?"}),CODE
LOW…s/common/sql/tests/unit/common/sql/hooks/test_dbapi.py521 extra=json.dumps({"placeholder": "!"}),CODE
LOW…mmon/sql/src/airflow/providers/common/sql/hooks/sql.py201 placeholder = self.connection_extra.get("placeholder")CODE
LOWproviders/odbc/src/airflow/providers/odbc/hooks/odbc.py153 extra_exclude = {"driver", "dsn", "connect_kwargs", "sqlalchemy_scheme", "placeholder"}CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py70 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py100 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py129 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py187 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py237 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py346 {"id": "dummy-id", "clientId": "dummy-client"},CODE
196 more matches not shown…
Overly Generic Function Names206 hits · 153 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/tests/conftest.py65 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py391 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py400 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py409 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py418 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py429 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py440 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py506 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py515 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py524 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py533 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py542 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py673 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py682 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py691 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py706 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py759 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py768 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py783 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1034 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1043 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1052 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1061 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1070 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1079 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1088 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1097 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1108 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1117 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1126 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1196 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1206 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1440 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1449 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1458 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1467 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1476 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1543 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1552 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1561 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1570 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1579 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1588 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py354 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py363 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py377 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py482 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py495 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py570 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py586 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py610 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py722 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py746 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py811 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py830 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1137 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1148 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1219 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1236 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1294 def handle_request(request: httpx.Request) -> httpx.Response:CODE
146 more matches not shown…
Verbosity Indicators80 hits · 118 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py679 # Step 1: Simulate CLI args being parsed (logical_date=None)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py704 # Step 3: Create the Pydantic model (what happens in the actual code)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py707 # Step 4: Verify logical_date was set to nowCOMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py693 # Step 2: Apply the defaulting logic (from cli_config.py lines 622-630)COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py667 # Step 1: create the dag run span and capture its carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py674 # 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.py684 # Step 3: build StartupDetails with ti.context_carrier = ti_carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py703 # Step 4: emit the worker span (task runner side).COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py709 # Step 5: emit the parent task span (API server side, as happens on task completion).COMMENT
LOWtask-sdk/src/airflow/sdk/bases/decorator.py133 # We need to check if we are in the context of TaskGroup as the task_id mayCOMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py91 # Step 1: Create with machine type A.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py102 # Step 2: Re-run with different machine type and recreate recreate_if_machine_type_different=True.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py114 # Step 3: Validate new machine type.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py120 # Step 4: Cleanup.COMMENT
LOW…iders/cncf/kubernetes/executors/kubernetes_executor.py691 # 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.py164 # Step 1: Decompose the high-level question into sub-questions,COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py193 # Step 2: Generate SQL for each sub-question in parallel.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py207 # Step 3: Wrap each SQL string into a single-element list.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py218 # Step 4: Execute each SQL against the survey CSV via DataFusion.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py229 # Step 5: Collect all four JSON results and label them by dimension.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py248 # Step 6: Synthesize the four labeled result sets into a narrative.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py267 # Step 7: Human reviews the synthesized narrative before the DAG ends.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py408 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py443 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py473 # Step 3: Map sub-questions to retrieval kwargs.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py490 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py526 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py541 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py567 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py599 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py420 # Step 1: Build the AIP list from the registry, using Confluence pageCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py454 # Step 2: Fetch the repo file tree from GitHub once, shared acrossCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py491 # Step 3: Gather evidence from Confluence, GitHub, and the file tree.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py601 # Step 4: Format the gathered evidence into an LLM analysis prompt.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py627 # Step 5: Analyze each AIP with a structured LLM call.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py643 # Step 6: Collect all per-AIP analyses into a combined context.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py660 # Step 7: Format the structured analyses as readable markdown.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py711 # Step 8: Synthesize a cross-AIP progress report.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py737 # Step 9: AI-powered hallucination validation.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py769 # Step 10: Apply validation corrections deterministically.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py849 # Step 11: Build the review body for the human reviewer, showingCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py888 # Step 12: A maintainer reviews the corrected report. The DAGCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py365 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py400 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py430 # Step 3: Map sub-questions to LlamaIndexRetrievalOperator kwargs.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py446 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py460 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py478 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py504 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py536 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py317 # Step 4: SQL generation -- LLM translates the fixed question.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py329 # Step 5: SQL execution via Apache DataFusion.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py339 # Step 6: Extract data rows from the JSON result.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py351 # Step 7: Send result via email if SMTP is configured, otherwise log.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py175 # Step 1: Prompt confirmation -- review or edit the question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py191 # Step 2: SQL generation -- LLM translates the confirmed question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py202 # Step 3: SQL execution via Apache DataFusion.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py212 # Step 4: Extract data rows from the JSON result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py225 # Step 5: Result confirmation -- approve or reject the query result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py271 # Step 1: Download the survey CSV from the Airflow website.STRING
20 more matches not shown…
Structural Annotation Overuse78 hits · 115 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py679 # Step 1: Simulate CLI args being parsed (logical_date=None)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py704 # Step 3: Create the Pydantic model (what happens in the actual code)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py707 # Step 4: Verify logical_date was set to nowCOMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py693 # Step 2: Apply the defaulting logic (from cli_config.py lines 622-630)COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py667 # Step 1: create the dag run span and capture its carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py674 # 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.py684 # Step 3: build StartupDetails with ti.context_carrier = ti_carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py703 # Step 4: emit the worker span (task runner side).COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py709 # Step 5: emit the parent task span (API server side, as happens on task completion).COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py91 # Step 1: Create with machine type A.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py102 # Step 2: Re-run with different machine type and recreate recreate_if_machine_type_different=True.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py114 # Step 3: Validate new machine type.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py120 # Step 4: Cleanup.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py164 # Step 1: Decompose the high-level question into sub-questions,COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py193 # Step 2: Generate SQL for each sub-question in parallel.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py207 # Step 3: Wrap each SQL string into a single-element list.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py218 # Step 4: Execute each SQL against the survey CSV via DataFusion.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py229 # Step 5: Collect all four JSON results and label them by dimension.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py248 # Step 6: Synthesize the four labeled result sets into a narrative.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py267 # Step 7: Human reviews the synthesized narrative before the DAG ends.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py408 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py443 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py473 # Step 3: Map sub-questions to retrieval kwargs.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py490 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py526 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py541 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py567 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py599 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py420 # Step 1: Build the AIP list from the registry, using Confluence pageCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py454 # Step 2: Fetch the repo file tree from GitHub once, shared acrossCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py491 # Step 3: Gather evidence from Confluence, GitHub, and the file tree.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py601 # Step 4: Format the gathered evidence into an LLM analysis prompt.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py627 # Step 5: Analyze each AIP with a structured LLM call.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py643 # Step 6: Collect all per-AIP analyses into a combined context.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py660 # Step 7: Format the structured analyses as readable markdown.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py711 # Step 8: Synthesize a cross-AIP progress report.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py737 # Step 9: AI-powered hallucination validation.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py769 # Step 10: Apply validation corrections deterministically.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py849 # Step 11: Build the review body for the human reviewer, showingCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py888 # Step 12: A maintainer reviews the corrected report. The DAGCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py365 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py400 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py430 # Step 3: Map sub-questions to LlamaIndexRetrievalOperator kwargs.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py446 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py460 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py478 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py504 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py536 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py317 # Step 4: SQL generation -- LLM translates the fixed question.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py329 # Step 5: SQL execution via Apache DataFusion.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py339 # Step 6: Extract data rows from the JSON result.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py351 # Step 7: Send result via email if SMTP is configured, otherwise log.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py175 # Step 1: Prompt confirmation -- review or edit the question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py191 # Step 2: SQL generation -- LLM translates the confirmed question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py202 # Step 3: SQL execution via Apache DataFusion.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py212 # Step 4: Extract data rows from the JSON result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py225 # Step 5: Result confirmation -- approve or reject the query result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py271 # Step 1: Download the survey CSV from the Airflow website.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py283 # Step 2: Write the downloaded CSV to disk and generate a referenceSTRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py302 # Step 3: Validate the downloaded CSV schema against the reference.STRING
18 more matches not shown…
AI Slop Vocabulary41 hits · 86 pts
SeverityFileLineSnippetContext
MEDIUMairflow-e2e-tests/docker/openlineage.yml27 # These DAGs are the only ones the harness drives; keep the stock example DAGs out of the way.COMMENT
MEDIUMairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py603 # so it must not also load the stock e2e dags — the harness triggers every dag it finds.COMMENT
MEDIUM…ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py45# The marker after which everything is Airflow's in-process test harness (pytest-only).COMMENT
MEDIUMtask-sdk/tests/task_sdk/bases/test_operator.py83# Essentially similar to airflow.models.baseoperator.BaseOperatorCOMMENT
LOWtask-sdk/src/airflow/sdk/execution_time/comms.py228 # `__class_getitem__`, but that's a lot of code the one subclass we've got currently. So we'll just use aCOMMENT
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2217# 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.py43# mock_get_conn. We then override it to just return the locally created self.client instead ofCOMMENT
LOW…/amazon/src/airflow/providers/amazon/aws/sensors/s3.py182 # Otherwise, just pass the filesCOMMENT
LOW…irflow/providers/amazon/aws/operators/redshift_data.py242 # case, pull each of the sub-statement ID's, and grab the results. Otherwise, just use statement_idCOMMENT
MEDIUM…viders/edge3/src/airflow/providers/edge3/cli/worker.py547 # Technically safer and more robust, but with more overheadCOMMENT
MEDIUM…irflow/providers/google/cloud/utils/field_validator.py350 # Certainly down from here the field is present (value is not None)COMMENT
LOW…w/providers/google/cloud/utils/credentials_provider.py498 # if it's already a dict, just return itCOMMENT
MEDIUM…rc/airflow/providers/google/cloud/hooks/compute_ssh.py42# TODO:(potiuk) We should add test harness detecting such cases shortlyCOMMENT
LOW…e/src/airflow/providers/snowflake/utils/openlineage.py107 # else - its new hostname, just return itCOMMENT
MEDIUM…/ai/src/airflow/providers/common/ai/operators/agent.py105 # Only report "extra not installed" when pydantic-ai-harness itself isCOMMENT
LOW…lineage/tests/unit/openlineage/extractors/test_base.py454 # just return empty OperatorLineageCOMMENT
MEDIUM…ders/openlineage/tests/system/openlineage/constants.py25# Overridable via env var — the e2e harness runs every DAG in the same deployment and wants aCOMMENT
LOW…lineage/src/airflow/providers/openlineage/utils/sql.py203 # Don't iterate over tables hierarchy, just pass it to query single information schema tableCOMMENT
LOW…e/src/airflow/providers/salesforce/hooks/salesforce.py252 # just return the original column untouchedCOMMENT
MEDIUMchart/values.yaml31# For now this is an opt-in switch for backwards compatibility to leverage the standard naming conventionCOMMENT
MEDIUMchart/values.yaml316# Specify executors in a prioritized list to leverage multiple execution environments as needed:COMMENT
MEDIUMchart/files/statsd-mappings.yml21# instead utilize `statsd.extraMappings` or `statsd.overrideMappings` in your environment,COMMENT
LOW…nfiguration/src/airflow_shared/configuration/parser.py1423 # have these types is with `fallback=` was specified. So just return it.COMMENT
LOW…ared/logging/src/airflow_shared/logging/_noncaching.py36 # we should simply return the wrapper retrieved by FileHandler's open methodCOMMENT
LOWairflow-core/tests/unit/cli/test_hot_reload.py63 # Should just call the callback directlyCOMMENT
LOW…/src/airflow/api_fastapi/execution_api/routes/xcoms.py359# TODO: once we have JWT tokens, then remove dag_id/run_id/task_id from the URL and just use the info inCOMMENT
MEDIUM…c/airflow/config_templates/default_webserver_config.py111# in order to fully utilize the theme. (or use that property in conjunction with theme)COMMENT
MEDIUM…c/airflow/config_templates/default_webserver_config.py111# in order to fully utilize the theme. (or use that property in conjunction with theme)COMMENT
LOWairflow-core/src/airflow/timetables/trigger.py289 # values, so we can just use the first to represent them.COMMENT
MEDIUMairflow-core/src/airflow/triggers/base.py485 """Yield this event in order to end the task successfully."""STRING
MEDIUMairflow-core/src/airflow/triggers/base.py491 """Yield this event in order to end the task with failure."""STRING
MEDIUMairflow-core/src/airflow/triggers/base.py497 """Yield this event in order to end the task with status 'skipped'."""STRING
LOWairflow-core/src/airflow/serialization/encoders.py413 # values, so we can just use the first to represent them.COMMENT
LOWairflow-core/src/airflow/utils/db.py1490 # Older version before we added that function, it only has a single migration so we can just create the tablesCOMMENT
LOWairflow-core/src/airflow/utils/dot_renderer.py241 # (we can just use the maybe-None label variable directly)COMMENT
LOWairflow-core/src/airflow/utils/sqlalchemy.py318 # below is the only line we change, and we just add default=None for getattrCOMMENT
LOW…core/src/airflow/utils/log/non_caching_file_handler.py31 # we should simply return the wrapper retrieved by FileHandler's open methodCOMMENT
LOWairflow-core/src/airflow/cli/commands/db_command.py66 # Exact match found, we can just return itCOMMENT
LOW…flow-core/src/airflow/dag_processing/importers/base.py238 # If it's a file, just return it if we can handle itCOMMENT
LOWdev/breeze/src/airflow_breeze/params/shell_params.py518 # Socket is something different (TCP?) just pass it through as DOCKER_HOST variableCOMMENT
MEDIUM…airflow_breeze/commands/release_management_commands.py2232 """Cleans up the old airflow providers artifacts in order to maintainSTRING
Slop Phrases28 hits · 68 pts
SeverityFileLineSnippetContext
LOWclients/python/test_python_client.py53# auth manager for instance AwsAuthManagerUser or SimpleAuthManager make sure to generate the token withCOMMENT
LOWairflow-ctl/src/airflowctl/api/client.py113 # If you are updating here don't forget to update the airflow-ctl-testsCOMMENT
LOWairflow-ctl/src/airflowctl/api/client.py113 # If you are updating here don't forget to update the airflow-ctl-testsCOMMENT
LOW…mazon/tests/system/amazon/aws/example_mwaa_airflow2.py58 # If creating the environment using the AWS console, make sure to have a VPC withCOMMENT
LOW…oviders/amazon/tests/system/amazon/aws/example_mwaa.py59 # If creating the environment using the AWS console, make sure to have a VPC withCOMMENT
MEDIUM…adata/src/airflow/providers/teradata/hooks/teradata.py84 # Optionally, you can replace the original value in the query_band_textCOMMENT
MEDIUM…stem/google/cloud/dataplex/example_dataplex_catalog.py80 "description": "A simple AspectType for demonstration purposes.",CODE
MEDIUM…ers/pgvector/tests/system/pgvector/example_pgvector.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, taskCOMMENT
MEDIUM…ector/tests/system/pgvector/example_pgvector_openai.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, task, teardownCOMMENT
MEDIUM…ineage/tests/unit/openlineage/plugins/test_listener.py395 # Now you can use listener and task_instance in your tests to simulate their interaction.STRING
MEDIUM…ineage/tests/unit/openlineage/plugins/test_listener.py1270 # Now you can use listener and task_instance in your tests to simulate their interaction.STRING
MEDIUM…airbyte/src/airflow/providers/airbyte/hooks/airbyte.py61 # Intentionally left the password out, you can modify the log to print it out if you are doing testing.COMMENT
MEDIUM…irflow/providers/apache/tinkerpop/operators/gremlin.py46 # If you prefer, you can add an alias run_query = run in your hook.COMMENT
MEDIUMproviders/openai/tests/system/openai/example_openai.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, taskCOMMENT
MEDIUMchart/values.yaml469 # or, you can use a different database like:COMMENT
MEDIUMchart/values.yaml569 # This is an example config showing how you can use templating and how "example" configCOMMENT
LOW…art/tests/helm_tests/airflow_aux/test_chart_quality.py36 # we don't forget to update the schema if we add a new propertyCOMMENT
LOW…art/tests/helm_tests/airflow_aux/test_chart_quality.py36 # we don't forget to update the schema if we add a new propertyCOMMENT
MEDIUM…low-core/docs/howto/docker-compose/docker-compose.yaml45# Feel free to modify this file to suit your needs.COMMENT
MEDIUM…low-core/docs/howto/docker-compose/docker-compose.yaml49 # In order to add custom dependencies or upgrade provider distributions you can use your extended image.COMMENT
MEDIUM…c/airflow/config_templates/default_webserver_config.py108# that you can use for Apache Airflow.COMMENT
LOW…c/airflow/config_templates/default_webserver_config.py110# Please make sure to remove "navbar_color" configuration from airflow.cfgCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py52 # Therefore you can add the "section" attribute.COMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py54 # Note if you can add any Markdown formatting to the description, you need to use the description_mdCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py69 # If you want to have a selection list box then you can use the enum feature of JSON schemaCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py168 # then you can use the examples feature of JSON schemaCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py288 # then you can use the JSON schema option of passing constant values. These parametersCOMMENT
LOWscripts/ci/prek/check_integrations_list.py201 "[yellow]Regenerating documentation table. Don't forget to review and commit possible changes.[/]"CODE
Docstring Block Structure12 hits · 60 pts
SeverityFileLineSnippetContext
HIGH…radata/src/airflow/providers/teradata/operators/tpt.py176 Normalize error_list parameter to a list of integers. Args: error_list: An integer, list oSTRING
HIGH…radata/src/airflow/providers/teradata/operators/tpt.py577 Handle execution using a local job variable file. Args: file_path: Path to the local job vSTRING
HIGH…s/teradata/src/airflow/providers/teradata/hooks/tpt.py86 Execute a DDL statement using TPT. Args: tpt_script: TPT script content as string or list STRING
HIGH…s/teradata/src/airflow/providers/teradata/hooks/tpt.py247 Execute a tdload operation using the tdload command-line utility. Args: remote_working_dirSTRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py63 Merge multiple column lineage facets into a single consolidated facet. Specifically, it aggregates input fieldSTRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py163 Extract and process the dataset name from a given path. Args: path: The path to process e.g. of a gcs STRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py276 Get column lineage facet for identity transformations. This function generates a simple column lineage facet, STRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py418 Replace the properties of a specific job type in a Dataproc job definition. Args: job: The original DaSTRING
HIGH…ndard/src/airflow/providers/standard/operators/hitl.py300 Generate a URL link to the "required actions" page for a specific task instance. This URL includes queSTRING
HIGH…e/tests/system/openlineage/expected_events/__init__.py31 Retrieve the file path to the OpenLineage expected events JSON file for a given DAG ID, taking into account theSTRING
HIGH…c/airflow/api_fastapi/core_api/services/ui/calendar.py291 Get database-specific time truncation expression for SQLAlchemy. We want to return always timestamp foSTRING
HIGH…sdk-integration-tests/tests/task_sdk_tests/conftest.py436 Utility to set up a DAG run and create an SDK client. This function handles the common pattern of: 1. GettSTRING
Modern AI Meta-Vocabulary17 hits · 53 pts
SeverityFileLineSnippetContext
MEDIUMpyproject.toml725# FastAPI dependency injection uses function calls in argument defaults intentionally.COMMENT
MEDIUMpyproject.toml801# Annotated is central for FastAPI dependency injection, skipping rules for FastAPI folders.COMMENT
MEDIUM.apache-magpie-overrides/README.md30[`docs/setup/agentic-overrides.md`](https://github.com/apache/magpie/blob/main/docs/setup/agentic-overrides.md)CODE
MEDIUM…viders/amazon/tests/system/amazon/aws/utils/bedrock.py49 # Haiku has some version dependency issues: RAG only supports 3.5 but batch only supports 4.5COMMENT
MEDIUM…/unit/common/ai/operators/test_llamaindex_retrieval.py101 # The retrieval-time embedding model is passed directly (no Settings mutation).COMMENT
MEDIUM…common/ai/tests/unit/common/ai/hooks/test_langchain.py96 # extra placeholder shows both chat and embedding model keysCOMMENT
MEDIUM…common/ai/example_dags/example_langchain_tool_agent.py217 # re-initialising the embedding model on every call would be wasteful.COMMENT
MEDIUM…iders/common/ai/example_dags/example_llamaindex_rag.py41# 1. Full RAG pipeline: load -> embed -> retrieve -> answerCOMMENT
MEDIUM…iders/common/ai/example_dags/example_llamaindex_rag.py192# 3. Multi-source RAG: combine CSV product data with text documentationCOMMENT
MEDIUM…common/ai/example_dags/example_aip_progress_tracker.py737 # Step 9: AI-powered hallucination validation.COMMENT
MEDIUM…irflow/providers/common/ai/example_dags/example_llm.py136 # tokens, or 1_000 output tokens. Useful for guardrails on sharedCOMMENT
MEDIUM.agents/skills/magpie-setup/overrides.md4# overrides — manage agentic overrides for framework skillsCOMMENT
MEDIUM.agents/skills/magpie-setup/overrides.md71## Override file scaffoldCOMMENT
MEDIUM.agents/skills/magpie-setup/adopt.md703[`docs/setup/agentic-overrides.md`](https://github.com/apache/magpie/blob/main/docs/setup/agentic-overrides.md)CODE
MEDIUM…flow-core/src/airflow/api_fastapi/execution_api/app.py404 # Set up dag_bag in app state for dependency injectionCOMMENT
MEDIUMairflow-core/src/airflow/models/trigger.py451 # It prioritizes callbacks, then DAGs over event driven scheduling which is fairCOMMENT
MEDIUM…c/adr/0017-use-uvx-to-run-breeze-from-local-sources.md91# so each worktree (e.g. parallel agentic runs) gets its own ephemerally-installedCOMMENT
Dead Code20 hits · 40 pts
SeverityFileLineSnippetContext
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py476CODE
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py489CODE
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1422CODE
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1616CODE
MEDIUM…ers/standard/tests/unit/standard/triggers/test_file.py260CODE
MEDIUMairflow-core/tests/unit/triggers/test_shared_stream.py192CODE
MEDIUMairflow-core/tests/unit/triggers/test_shared_stream.py2552CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1228CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py622CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py693CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py709CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py735CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py908CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py925CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1266CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1313CODE
MEDIUMairflow-core/tests/unit/models/test_dagrun.py3934CODE
MEDIUMairflow-core/src/airflow/triggers/base.py188CODE
MEDIUMairflow-core/src/airflow/triggers/base.py382CODE
MEDIUMairflow-core/src/airflow/triggers/base.py425CODE
Synthetic Comment Markers2 hits · 8 pts
SeverityFileLineSnippetContext
HIGH…rc/airflow/providers/edge3/example_dags/win_notepad.py72 "This is a text as proposal generated by Airflow DAG. Change it and save and it will get to XCom.",CODE
HIGH…cncf/kubernetes/executors/kubernetes_executor_utils.py790 :param kube_config: The KubeConfig class generated by airflow that contains all kube metadataSTRING
Example Usage Blocks5 hits · 8 pts
SeverityFileLineSnippetContext
LOWproviders/informatica/dev/docker-compose.yml20# Usage:COMMENT
LOWjava-sdk/scripts/ci/verify-source-release.sh22# Usage:COMMENT
LOWjava-sdk/scripts/ci/smoke-test-staged-binaries.sh25# Usage:COMMENT
LOWdev/prune_old_dirs.py22# Usage:COMMENT
LOWdev/sync_fork.sh28# Usage:COMMENT
AI Response Leakage1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…src/airflow/example_dags/example_params_ui_tutorial.py128 # In this example we have no default valueCOMMENT