Fuzz introspector
For issues and ideas: https://github.com/ossf/fuzz-introspector/issues
Project coverage

Table of contents

Project overview: airflow
High level conclusions
Reachability and coverage overview
Fuzzers overview
Project functions overview
Fuzzer details
Fuzzer: dag_fuzz
Call tree
Fuzz blockers
Runtime coverage analysis
Files reached
Analyses and suggestions
Optimal target analysis
Remaining optimal interesting functions
All functions overview
Fuzz engine guidance
dag_fuzz.py
Dictionary
Fuzzer function priority
Runtime coverage analysis
Complex functions with low coverage
Files and Directories in report
Files in report
Directories in report
Metadata section
Report generation date: 2025-12-31

Project overview: airflow

High level conclusions

Reachability and coverage overview

Functions statically reachable by fuzzers
0.0%
1 / 5631
Cyclomatic complexity statically reachable by fuzzers
0.0%
4 / 19134
Runtime code coverage of functions
9.0%
498 / 5631

Warning: The number of runtime covered functions are larger than the number of reachable functions. This means that Fuzz Introspector found there are more functions covered at runtime than what is considered reachable based on the static analysis. This is a limitation in the analysis as anything covered at runtime is by definition reachable by the fuzzers.
This is likely due to a limitation in the static analysis. In this case, the count of functions covered at runtime is the true value, which means this is what should be considered "achieved" by the fuzzer.

Use the project functions table below to query all functions that were not covered at runtime.

Fuzzers overview

Fuzzer Fuzzer filename Functions Reached Functions unreached Fuzzer depth Files reached Basic blocks reached Cyclomatic complexity Details
dag_fuzz dag_fuzz.py 16 10564 2 3 2 46 dag_fuzz.py

Project functions overview

The following table shows data about each function in the project. The functions included in this table correspond to all functions that exist in the executables of the fuzzers. As such, there may be functions that are from third-party libraries.

For further technical details on the meaning of columns in the below table, please see the Glossary .

Func name Functions filename Args Function call depth Reached by Fuzzers Runtime reached by Fuzzers Combined reached by Fuzzers Fuzzers runtime hit Func lines hit % I Count BB Count Cyclomatic complexity Functions reached Reached by functions Accumulated cyclomatic complexity Undiscovered complexity

Fuzzer details

Fuzzer: dag_fuzz

Call tree

The calltree shows the control flow of the fuzzer. This is overlaid with coverage information to display how much of the potential code a fuzzer can reach is in fact covered at runtime. In the following there is a link to a detailed calltree visualisation as well as a bitmap showing a high-level view of the calltree. For further information about these topics please see the glossary for full calltree and calltree overview

Full calltree

Call tree overview bitmap:

The distribution of callsites in terms of coloring is
Color Runtime hitcount Callsite count Percentage
red 0 23 88.4%
gold [1:9] 0 0.0%
yellow [10:29] 0 0.0%
greenyellow [30:49] 0 0.0%
lawngreen 50+ 3 11.5%
All colors 26 100

Fuzz blockers

The following nodes represent call sites where fuzz blockers occur.

Amount of callsites blocked Calltree index Parent function Callsite Largest blocked function
12 13 ...dag_fuzz.TestInput call site: 00013 airflow.providers.standard.operators.python.PythonOperator.__init__
11 1 ...dag_fuzz.TestInput call site: 00001 fdp.ConsumeString

Runtime coverage analysis

Covered functions
819
Functions that are reachable but not covered
16
Reachable functions
16
Percentage of reachable functions covered
0.0%
NB: The sum of covered functions and functions that are reachable but not covered need not be equal to Reachable functions . This is because the reachability analysis is an approximation and thus at runtime some functions may be covered that are not included in the reachability analysis. This is a limitation of our static analysis capabilities.
Warning: The number of covered functions are larger than the number of reachable functions. This means that there are more functions covered at runtime than are extracted using static analysis. This is likely a result of the static analysis component failing to extract the right call graph or the coverage runtime being compiled with sanitizers in code that the static analysis has not analysed. This can happen if lto/gold is not used in all places that coverage instrumentation is used.
Function name source code lines source lines hit percentage hit

Files reached

filename functions hit
/ 1
...dag_fuzz 13
airflow.providers.standard.operators.python 2

Analyses and suggestions

Optimal target analysis

Remaining optimal interesting functions

The following table shows a list of functions that are optimal targets. Optimal targets are identified by finding the functions that in combination, yield a high code coverage.

Func name Functions filename Arg count Args Function depth hitcount instr count bb count cyclomatic complexity Reachable functions Incoming references total cyclomatic complexity Unreached complexity
airflow.utils.cli.action_cli.action_logging.wrapper airflow.utils.cli 2 ['N/A', 'N/A'] 48 0 8 3 4 2439 0 8000 7988

Implementing fuzzers that target the above functions will improve reachability such that it becomes:

Functions statically reachable by fuzzers
18.0%
1024 / 5631
Cyclomatic complexity statically reachable by fuzzers
20.0%
3748 / 19134

All functions overview

If you implement fuzzers for these functions, the status of all functions in the project will be:

Func name Functions filename Args Function call depth Reached by Fuzzers Runtime reached by Fuzzers Combined reached by Fuzzers Fuzzers runtime hit Func lines hit % I Count BB Count Cyclomatic complexity Functions reached Reached by functions Accumulated cyclomatic complexity Undiscovered complexity

Fuzz engine guidance

This sections provides heuristics that can be used as input to a fuzz engine when running a given fuzz target. The current focus is on providing input that is usable by libFuzzer.

dag_fuzz.py

Dictionary

Use this with the libFuzzer -dict=DICT.file flag


Fuzzer function priority

Use one of these functions as input to libfuzzer with flag: -focus_function name 

-focus_function=['...dag_fuzz.TestInput']

Runtime coverage analysis

This section shows analysis of runtime coverage data.

For futher technical details on how this section is generated, please see the Glossary .

Complex functions with low coverage

Func name Function total lines Lines covered at runtime percentage covered Reached by fuzzers
datetime.datetime.combine 511 189 36.98% ['dag_fuzz']
airflow.providers.standard.operators.python._BasePythonVirtualenvOperator._execute_python_callable_in_subprocess 37 0 0.0% []
io.BytesIO 351 152 43.30% ['dag_fuzz']
traceback.format_tb 303 78 25.74% ['dag_fuzz']
airflow.utils.log.file_task_handler.FileTaskHandler._read 48 1 2.083% ['dag_fuzz']
packaging.version.Version 175 33 18.85% ['dag_fuzz']
airflow.providers_manager.ProvidersManager._import_hook 48 0 0.0% []
airflow.plugins_manager._load_plugins_from_plugin_directory 36 0 0.0% []
airflow.plugins_manager._get_ui_plugins 40 0 0.0% []
time.time 496 178 35.88% ['dag_fuzz']
info.logical_date.timestamp 40 17 42.5% ['dag_fuzz']
airflow.sdk.bases.operator.partial 34 5 14.70% ['dag_fuzz']
airflow.sdk.bases.operator.BaseOperatorMeta._apply_defaults.apply_defaults 42 3 7.142% ['dag_fuzz']
airflow.sdk.bases.operator.BaseOperator.__init__ 89 0 0.0% []
pydantic.BaseModel.from_orm 56 27 48.21% ['dag_fuzz']
e.add_note 227 76 33.48% ['dag_fuzz']
pygtrie.StringTrie 610 221 36.22% ['dag_fuzz']
itertools.dropwhile 64 11 17.18% ['dag_fuzz']
result.strip 55 28 50.90% ['dag_fuzz']
level.lower 87 44 50.57% ['dag_fuzz']
key.split 323 122 37.77% ['dag_fuzz']
pattern.rstrip 56 25 44.64% ['dag_fuzz']
buffer.find 63 16 25.39% ['dag_fuzz']
date.isoformat 280 100 35.71% ['dag_fuzz']
airflow.executors.executor_loader.ExecutorLoader._get_executor_names 31 0 0.0% []
airflow.models.variable.Variable.set 33 0 0.0% []
airflow.sdk.execution_time.context.context_to_airflow_vars 34 0 0.0% []
airflow.sdk.definitions.dag.DAG.partial_subset.filter_task_group 31 0 0.0% []
airflow.sdk.definitions.dag.DAG.test 107 0 0.0% []
airflow.sdk.definitions.dag._run_task 42 0 0.0% []
val.is_expired 209 76 36.36% ['dag_fuzz']
data.replace 137 38 27.73% ['dag_fuzz']
t.infer_manual_data_interval 35 19 54.28% ['dag_fuzz']
query.selectable.compile 800 339 42.37% ['dag_fuzz']
airflow.configuration.AirflowConfigParser.write_custom_config 45 0 0.0% []
match.groups 170 31 18.23% ['dag_fuzz']
typing_extensions.ParamSpec 1716 561 32.69% ['dag_fuzz']
output.put 136 55 40.44% ['dag_fuzz']
airflow._shared.secrets_masker.secrets_masker.SecretsMasker._merge 34 0 0.0% []
cryptography.fernet.MultiFernet 146 37 25.34% ['dag_fuzz']
opt.lower 43 11 25.58% ['dag_fuzz']
dict.fromkeys 61 15 24.59% ['dag_fuzz']
asyncio.open_connection 235 117 49.78% ['dag_fuzz']
airflow.sdk.execution_time.task_runner.RuntimeTaskInstance.xcom_pull 35 0 0.0% []
airflow.sdk.execution_time.task_runner.startup 32 0 0.0% []
airflow.sdk.execution_time.task_runner.run._on_term 79 0 0.0% []
airflow.sdk.execution_time.task_runner._handle_trigger_dag_run 34 0 0.0% []
airflow.sdk.execution_time.task_runner._execute_task 42 0 0.0% []
airflow.sdk.execution_time.task_runner.finalize 46 0 0.0% []
ds.replace 49 12 24.48% ['dag_fuzz']
airflow.dag_processing.bundles.manager.DagBundlesManager.sync_bundles_to_db._extract_and_sign_template 50 0 0.0% []
airflow.sdk._shared.secrets_masker.secrets_masker.SecretsMasker._merge 34 0 0.0% []
airflow.sdk.serde.serialize 43 0 0.0% []
airflow.sdk.serde.deserialize 49 0 0.0% []
contextvars.ContextVar 66 27 40.90% ['dag_fuzz']
airflow.sdk._shared.configuration.parser.AirflowConfigParser._resolve_deprecated_lookup 33 17 51.51% ['dag_fuzz']
attributes.items 1003 383 38.18% ['dag_fuzz']
readers.append 131 31 23.66% ['dag_fuzz']
model.model_dump 65 34 52.30% ['dag_fuzz']
i.get 211 52 24.64% ['dag_fuzz']
dateutil.relativedelta.relativedelta.normalized 243 36 14.81% ['dag_fuzz']
pendulum.tz.local_timezone 150 27 18.0% ['dag_fuzz']
rich.console.Console.export_text 1017 271 26.64% ['dag_fuzz']
rich.markup.escape 121 27 22.31% ['dag_fuzz']
default.copy 113 40 35.39% ['dag_fuzz']
textwrap.indent 45 12 26.66% ['dag_fuzz']
signature.parameters.items 83 14 16.86% ['dag_fuzz']
airflow.sdk.definitions._internal.node.DAGNode._set_relatives 32 0 0.0% []
template.stream 173 32 18.49% ['dag_fuzz']
jinja2.nativetypes.NativeEnvironment 68 30 44.11% ['dag_fuzz']
jinja2.sandbox.is_internal_attribute 161 52 32.29% ['dag_fuzz']
action._prog_prefix.replace 52 16 30.76% ['dag_fuzz']
tenacity.after_log 350 172 49.14% ['dag_fuzz']
dates.items 731 86 11.76% ['dag_fuzz']
pathspec.patterns.GitWildMatchPattern 92 29 31.52% ['dag_fuzz']
content.encode 131 35 26.71% ['dag_fuzz']
ast.literal_eval 94 7 7.446% ['dag_fuzz']
importlib_metadata.distributions 498 238 47.79% ['dag_fuzz']
tempfile.NamedTemporaryFile 195 95 48.71% ['dag_fuzz']
airflow.config_templates.airflow_local_settings._default_conn_name_from 81 1 1.234% ['dag_fuzz']
connection.get_uri 219 48 21.91% ['dag_fuzz']
managers.append 71 30 42.25% ['dag_fuzz']
airflow.providers.standard.utils.skipmixin.SkipMixin.skip_all_except 31 0 0.0% []
mapping.items 107 29 27.10% ['dag_fuzz']
airflow.providers.common.compat.sdk.BaseOperator._do_render_template_fields 31 14 45.16% ['dag_fuzz']
airflow.providers.common.compat._compat_utils.create_module_getattr.__getattr__ 42 12 28.57% ['dag_fuzz']
fsspec.implementations.local.LocalFileSystem 349 81 23.20% ['dag_fuzz']
airflow.sdk.io.path.ObjectStoragePath.copy 31 0 0.0% []
fsspec.utils.compressions.items 352 46 13.06% ['dag_fuzz']
upath.implementations.cloud.CloudPath.joinpath 58 25 43.10% ['dag_fuzz']
upath.registry.get_upath_class.home 87 38 43.67% ['dag_fuzz']
compiler.process 1205 183 15.18% ['dag_fuzz']
registry.register_value 56 16 28.57% ['dag_fuzz']
validator.avalidated_claims 74 25 33.78% ['dag_fuzz']
spec.items 889 182 20.47% ['dag_fuzz']
columns.append 100 18 18.0% ['dag_fuzz']
thread.join 224 75 33.48% ['dag_fuzz']
uuid6.uuid7 88 24 27.27% ['dag_fuzz']
tenacity.retry 144 65 45.13% ['dag_fuzz']
tty.setcbreak 402 87 21.64% ['dag_fuzz']
array.array 133 54 40.60% ['dag_fuzz']
pool.model_dump 171 35 20.46% ['dag_fuzz']
options.items 792 240 30.30% ['dag_fuzz']
expression.split 1585 762 48.07% ['dag_fuzz']
cursor.fetchone 72 34 47.22% ['dag_fuzz']
statement.replace 1743 713 40.90% ['dag_fuzz']
zoneinfo.ZoneInfo 57 10 17.54% ['dag_fuzz']
pendulum.time 131 49 37.40% ['dag_fuzz']
rich.syntax.Syntax 351 90 25.64% ['dag_fuzz']
rich.table.Table.add_row 412 102 24.75% ['dag_fuzz']
pygments.lexers.configs.IniLexer 192 35 18.22% ['dag_fuzz']
word.split 107 35 32.71% ['dag_fuzz']
url.get_backend_name 259 120 46.33% ['dag_fuzz']
color.get 196 88 44.89% ['dag_fuzz']
rich.print 35 15 42.85% ['dag_fuzz']
sql.strip 59 26 44.06% ['dag_fuzz']
part.endswith 164 39 23.78% ['dag_fuzz']
glob.glob 39 14 35.89% ['dag_fuzz']

Files and Directories in report

This section shows which files and directories are considered in this report. The main reason for showing this is fuzz introspector may include more code in the reasoning than is desired. This section helps identify if too many files/directories are included, e.g. third party code, which may be irrelevant for the threat model. In the event too much is included, fuzz introspector supports a configuration file that can exclude data from the report. See the following link for more information on how to create a config file: link

Files in report

Source file Reached by Covered by
[] []
multiprocessing [] []
airflow.providers.standard.example_dags.example_external_task_parent_deferrable [] []
airflow.providers.standard.operators.weekday [] []
airflow.cli.commands [] []
airflow.providers.standard.sensors [] []
airflow.example_dags.standard.example_external_task_parent_deferrable [] []
more_itertools [] []
airflow.utils.retries [] []
airflow.providers.common.compat.openlineage.utils.spark [] []
airflow.sdk._shared.logging.structlog [] []
airflow.datasets.metadata [] []
airflow.api_fastapi.execution_api.versions.v2025_12_08 [] []
airflow.api_fastapi.core_api.services.public.pools [] []
airflow.api_fastapi.core_api.routes.ui.grid [] []
airflow.ti_deps.deps.task_not_running_dep [] []
airflow.serialization.definitions.taskgroup [] []
airflow.__main__ [] []
airflow.models.expandinput [] []
airflow.ti_deps.deps.mapped_task_expanded [] []
airflow.providers.common.io.xcom [] []
airflow.sdk.definitions.dag [] []
platform [] []
airflow.api_fastapi.core_api.routes.public.dags [] []
airflow.providers.standard.decorators [] []
airflow.api_fastapi.core_api.datamodels [] []
pty [] []
airflow.api_fastapi.common.headers [] []
airflow.providers.smtp [] []
airflow.sdk.serde.serializers.uuid [] []
airflow.providers.standard.example_dags.example_bash_decorator [] []
airflow.providers.common.compat.assets [] []
airflow.ti_deps.deps.exec_date_after_start_date_dep [] []
airflow.example_dags.standard.example_bash_operator [] []
airflow.example_dags.example_workday_timetable [] []
airflow.providers.standard.decorators.branch_virtualenv [] []
airflow.logging.remote [] []
jsonschema [] []
airflow.api_fastapi.auth.middlewares [] []
airflow.providers.common.compat.standard.operators [] []
lockfile [] []
airflow.serialization [] []
contextvars [] []
airflow.example_dags.plugins [] []
airflow.providers.common.sql.hooks [] []
airflow.api_fastapi.core_api.datamodels.config [] []
airflow.api_fastapi.execution_api.datamodels.hitl [] []
logging [] []
airflow.sdk._shared.logging.percent_formatter [] []
faulthandler [] []
codecs [] []
airflow.migrations.versions.0009_2_9_0_add_rendered_map_index_to_taskinstance [] []
airflow.models.taskinstancehistory [] []
airflow.example_dags.libs [] []
ipaddress [] []
airflow.migrations.versions.0084_3_1_0_add_last_parse_duration_to_dag_model [] []
airflow._shared.logging.types [] []
airflow.macros [] []
airflow.migrations.versions.0069_3_0_3_delete_import_errors [] []
airflow.providers.common.sql.triggers [] []
airflow.sdk.definitions.operator_resources [] []
airflow.sdk._shared.observability.exceptions [] []
airflow.providers.standard.exceptions [] []
airflow.listeners.spec [] []
airflow.api.common.mark_tasks [] []
airflow.sdk.execution_time.xcom [] []
fnmatch [] []
airflow.api_fastapi.execution_api.versions.v2025_05_20 [] []
airflow.api_fastapi.auth.managers.simple.services [] []
airflow.sdk.execution_time.sentry [] []
airflow.example_dags.example_time_delta_sensor_async [] []
airflow.providers.common.compat.check [] []
airflow.api_fastapi.core_api.datamodels.backfills [] []
airflow.api_fastapi.core_api.routes [] []
airflow.example_dags.standard.example_short_circuit_operator [] []
airflow.api_fastapi.core_api.routes.public.config [] []
airflow.api_fastapi.core_api.routes.public.dag_parsing [] []
ssl [] []
airflow.providers.standard.utils.python_virtualenv [] []
airflow.migrations.versions.0055_3_0_0_remove_pickled_data_from_dagrun_table [] []
airflow.api_fastapi.core_api.routes.public.event_logs [] []
airflow.providers.smtp.version_compat [] []
airflow.providers.standard.example_dags.example_trigger_controller_dag [] []
airflow.migrations.versions.0047_3_0_0_add_dag_versioning [] []
airflow.migrations.versions.0026_2_10_0_dag_schedule_dataset_alias_reference [] []
airflow.jobs.job [] []
airflow.timetables.base [] []
airflow.api_fastapi.execution_api.routes.asset_events [] []
airflow.api_fastapi.auth.managers.simple.simple_auth_manager [] []
datetime [] []
airflow.api_fastapi.core_api.routes.public.auth [] []
airflow.providers.standard.sensors.bash [] []
airflow.utils.cli_action_loggers [] []
airflow.sdk.execution_time.secrets_masker [] []
airflow.api_fastapi.execution_api.routes.health [] []
airflow.migrations.versions.0073_3_1_0_add_task_inlet_asset_reference [] []
airflow.migrations.versions.0014_2_9_0_add_display_name_for_dag_and_task_ [] []
airflow.api_fastapi.auth.managers.models.base_user [] []
airflow.api_fastapi.main [] []
asgiref [] []
airflow.utils.log.timezone_aware [] []
airflow.timetables.trigger [] []
airflow.api_fastapi.core_api.services.ui [] []
airflow.providers.standard.example_dags.example_external_task_marker_dag [] []
airflow.models.dagwarning [] []
airflow.configuration [] []
airflow.sdk._shared.observability.metrics.base_stats_logger [] []
airflow.ti_deps [] []
airflow.migrations.versions.0027_2_10_3_fix_dag_schedule_dataset_alias_reference_naming [] []
airflow.providers.common.compat.security.permissions [] []
airflow.providers.standard.operators.datetime [] []
airflow.sdk.bases.secrets_backend [] []
airflow.sdk.definitions.timetables [] []
airflow.hooks [] []
deprecated [] []
airflow.utils.context [] []
airflow.migrations.versions.0034_3_0_0_remove_redundant_index [] []
airflow.models.dagbag [] []
colorlog [] []
airflow.models.connection [] []
airflow.utils.file [] []
duckdb [] []
airflow.providers.common.compat.openlineage.facet [] []
airflow.example_dags.example_asset_with_watchers [] []
airflow.providers.common.compat.version_compat [] []
airflow.cli.commands.rotate_fernet_key_command [] []
airflow.providers.common.compat.lineage [] []
airflow.sdk.serde.serializers.bignum [] []
airflow.example_dags.standard.example_branch_day_of_week_operator [] []
airflow.executors.executor_loader [] []
airflow.api_fastapi.execution_api.routes.assets [] []
airflow.ti_deps.deps.base_ti_dep [] []
airflow.api_fastapi.core_api.services.ui.grid [] []
airflow.utils.platform [] []
airflow.api_fastapi.core_api.routes.public.plugins [] []
airflow.sdk.io.stat [] []
airflow.models.taskreschedule [] []
airflow.example_dags.tutorial [] []
airflow.example_dags.example_assets [] []
airflow.api_fastapi.compat [] []
airflow.providers.standard.decorators.branch_python [] []
airflow.api_fastapi.core_api.services.public.providers [] []
airflow.utils.entry_points [] []
airflow.migrations.versions.0078_3_1_0_add_callback_state_to_deadline [] []
airflow.listeners.spec.importerrors [] []
airflow.utils.db_cleanup [] []
sqlalchemy_utils [] []
airflow.secrets.metastore [] []
airflow.sdk.definitions.decorators.task_group [] []
colorama [] []
rich [] []
airflow.sdk._shared.observability.metrics.validators [] []
airflow.ti_deps.dependencies_states [] []
airflow.example_dags.example_latest_only_with_trigger [] []
airflow.sdk.serde.serializers.deltalake [] []
airflow.example_dags.standard.example_python_decorator [] []
airflow.cli.commands.backfill_command [] []
airflow.providers.common.sql.sensors.sql [] []
airflow.api_fastapi.execution_api.versions.v2025_11_07 [] []
threading [] []
...dag_fuzz ['dag_fuzz'] []
airflow.api_fastapi.core_api.services.ui.structure [] []
airflow.example_dags.standard.example_latest_only [] []
airflow.models.deadline [] []
airflow.operators [] []
airflow.logging [] []
termcolor [] []
airflow.providers.common.io.version_compat [] []
dataclasses [] []
airflow.utils.db_manager [] []
airflow.notifications [] []
airflow.sdk._shared.configuration.exceptions [] []
importlib [] []
airflow.sdk.serde.typing [] []
airflow.api_fastapi.core_api.datamodels.ui.grid [] []
airflow.migrations.versions.0074_3_1_0_add_triggering_user_to_dag_run [] []
wtforms [] []
airflow.api_fastapi.execution_api.versions [] []
polars [] []
shlex [] []
airflow.utils.operator_helpers [] []
airflow.api_fastapi.execution_api.versions.v2025_11_05 [] []
airflow.example_dags.example_params_ui_tutorial [] []
airflow.migrations.versions.0083_3_1_0_add_teams [] []
airflow.migrations.versions.0050_3_0_0_add_dagbundlemodel [] []
airflow.migrations.versions.0008_2_8_1_refactor_dag_run_indexes [] []
warnings [] []
airflow._shared.logging [] []
airflow.api_fastapi.core_api.routes.public.providers [] []
airflow.triggers.base [] []
airflow.jobs.triggerer_job_runner [] []
airflow.ti_deps.deps.valid_state_dep [] []
airflow.sdk.execution_time.lazy_sequence [] []
airflow.providers.standard.example_dags.example_sensors [] []
airflow.cli.commands.jobs_command [] []
airflow.utils.docs [] []
airflow.cli.commands.db_manager_command [] []
airflow.migrations.versions.0031_3_0_0_add_triggered_by_field_to_dagrun [] []
airflow.api_fastapi.core_api.routes.public.tasks [] []
airflow.api_fastapi.core_api.routes.public.xcom [] []
airflow.example_dags.example_skip_dag [] []
svcs [] []
airflow.serialization.definitions.operatorlink [] []
airflow.providers.standard.version_compat [] []
airflow.migrations.versions.0076_3_1_0_add_human_in_the_loop_response [] []
airflow.sdk._shared.observability.metrics [] []
airflow.cli.utils [] []
sqlparse [] []
airflow.api_fastapi.execution_api.routes.connections [] []
airflow.providers.standard.get_provider_info [] []
airflow.cli.commands.info_command [] []
airflow.providers.standard.operators.branch [] []
itertools [] []
deltalake [] []
airflow.callbacks.callback_requests [] []
airflow._shared.logging._config [] []
airflow.sdk._shared.observability.metrics.statsd_logger [] []
airflow.example_dags.standard.example_branch_datetime_operator [] []
airflow.ti_deps.deps.trigger_rule_dep [] []
airflow.executors.workloads [] []
pandas [] []
datadog [] []
airflow.example_dags.standard [] []
airflow.example_dags.example_simplest_dag [] []
airflow.providers.smtp.get_provider_info [] []
airflow.api_fastapi.core_api.datamodels.ui.teams [] []
airflow._shared.observability.traces.utils [] []
array [] []
airflow.api_fastapi.execution_api.versions.v2026_03_31 [] []
airflow.example_dags.standard.example_hitl_operator [] []
airflow.providers.common.io.assets.file [] []
airflow.api_fastapi.execution_api.datamodels.xcom [] []
airflow.utils.deprecation_tools [] []
fsspec [] []
starlette [] []
airflow.sdk.serde.serializers.iceberg [] []
airflow.example_dags.standard.example_branch_operator_decorator [] []
airflow.example_dags.standard.sql [] []
airflow.api_fastapi.core_api.datamodels.task_instance_history [] []
airflow.migrations.versions.0056_3_0_0_add_relative_fileloc_column [] []
airflow.api_fastapi.core_api.routes.ui.teams [] []
subprocess [] []
airflow.api_fastapi.core_api.openapi [] []
airflow.sdk.bases.decorator [] []
airflow.serialization.json_schema [] []
airflow.serialization.typing [] []
airflow.migrations.versions.0085_3_1_0_downgrade_serialized_dag_version_to_v2 [] []
airflow [] []
airflow.utils.state [] []
pathlib [] []
fastapi [] []
pathspec [] []
airflow.api_fastapi.core_api.datamodels.common [] []
airflow.api.common.airflow_health [] []
airflow.serialization.dag_dependency [] []
unittest [] []
airflow.api_fastapi.core_api.services.public.config [] []
airflow.migrations.versions.0004_2_8_0_add_clear_number_to_dag_run [] []
csv [] []
airflow.sdk._shared.logging.types [] []
airflow.sdk.serde.serializers.pydantic [] []
airflow.utils.log.logging_mixin [] []
airflow.api_fastapi.auth.managers.simple.datamodels.login [] []
airflow.models [] []
cryptography [] []
functools [] []
airflow.sdk.definitions.edges [] []
airflow.jobs.scheduler_job_runner [] []
babel [] []
airflow.migrations.versions.0035_3_0_0_update_user_id_type [] []
airflow.providers.common.compat.get_provider_info [] []
airflow._shared.secrets_backend [] []
airflow.api_fastapi.auth.managers.simple.routes [] []
airflow.serialization.serialized_objects [] []
upath [] []
airflow.providers.common.sql.triggers.sql [] []
airflow.migrations.versions.0054_3_0_0_add_asset_reference_models [] []
airflow.task [] []
airflow.task.priority_strategy [] []
airflow.api_fastapi.core_api.routes.public.job [] []
airflow.sdk.definitions.timetables.trigger [] []
libcst [] []
airflow.sdk.execution_time.secrets [] []
airflow.providers_manager [] []
airflow.api_fastapi.core_api.datamodels.tasks [] []
airflow.api_fastapi.core_api.routes.public.monitor [] []
airflow.models.taskmap [] []
airflow.sdk._shared.logging._noncaching [] []
airflow.api_fastapi.auth.managers.models.batch_apis [] []
airflow.api_fastapi.core_api.datamodels.pools [] []
airflow.migrations.versions.0003_2_7_0_add_include_deferred_column_to_pool [] []
airflow.providers.common.compat.openlineage.check [] []
airflow.api_fastapi.core_api.datamodels.xcom [] []
airflow.api_fastapi.common.types [] []
airflow._shared.observability.metrics.validators [] []
airflow.providers.standard.example_dags.example_branch_operator_decorator [] []
pendulum [] []
airflow.migrations.versions.0053_3_0_0_remove_processor_subdir [] []
airflow.api_fastapi.auth.managers.simple.openapi [] []
packaging [] []
airflow.models.dagbundle [] []
airflow.api_fastapi.core_api.base [] []
airflow.api_fastapi.core_api.datamodels.extra_links [] []
airflow.api_fastapi.core_api.datamodels.assets [] []
airflow.api_fastapi.core_api.routes.public.pools [] []
airflow.sdk.definitions.variable [] []
airflow.sdk.observability.trace [] []
airflow.sdk.bases.xcom [] []
airflow.api_fastapi.auth.middlewares.refresh_token [] []
airflow.settings [] []
airflow.utils.serve_logs [] []
airflow.assets.manager [] []
airflow.api_fastapi.auth.managers.models [] []
airflow.cli.commands.legacy_commands [] []
airflow.sdk.io [] []
airflow.sdk.serde.serializers.timezone [] []
airflow.sdk.execution_time.comms [] []
airflow.migrations.versions.0095_3_2_0_enforce_log_event_and_dag_is_stale_not_null [] []
airflow._shared.observability.metrics.base_stats_logger [] []
airflow.sdk.observability.metrics [] []
airflow.utils.log.file_task_handler [] []
airflow.api_fastapi.core_api.routes.public.log [] []
airflow.providers.smtp.hooks.smtp [] []
airflow.example_dags.example_setup_teardown_taskflow [] []
airflow.example_dags.example_local_kubernetes_executor [] []
airflow.migrations.versions.0006_2_8_0_make_connection_login_password_text [] []
airflow.migrations.versions.0017_2_9_2_fix_inconsistency_between_ORM_and_migration_files [] []
airflow.migrations.versions.0087_3_2_0_change_serialized_dag_data_column_to_jsonb [] []
airflow.providers.standard.hooks.package_index [] []
airflow.providers.common.io.operators [] []
airflow.migrations.versions.0080_3_1_0_modify_deadline_callback_schema [] []
airflow.utils.code_utils [] []
airflow.providers.standard.sensors.date_time [] []
airflow.providers.common.io.assets [] []
airflow.serialization.helpers [] []
airflow.providers.standard.example_dags.example_branch_operator [] []
airflow.lineage [] []
airflow.sdk.observability.stats [] []
airflow.cli.commands.db_command [] []
airflow.api_fastapi.common.db.task_instances [] []
airflow.models.taskmixin [] []
airflow.serialization.definitions.notset [] []
airflow.utils.cli [] []
airflow.security.kerberos [] []
airflow.migrations.versions.0039_3_0_0_tweak_assetaliasmodel_to_match_asset [] []
airflow.sdk.definitions.taskgroup [] []
airflow.models.renderedtifields [] []
airflow.cli.commands.daemon_utils [] []
airflow.listeners.spec.lifecycle [] []
configparser [] []
airflow.providers.standard.operators.trigger_dagrun [] []
airflow.api_fastapi.core_api.datamodels.connections [] []
airflow.api_fastapi.core_api.routes.public.backfills [] []
airflow.providers.standard.utils.openlineage [] []
airflow.example_dags.example_complex [] []
copy [] []
airflow.secrets.local_filesystem [] []
airflow.api_fastapi.core_api.datamodels.plugins [] []
airflow.api_fastapi.common.parameters [] []
airflow.migrations.versions.0079_3_1_0_add_url_and_template_params_to_dagbundle_model [] []
kubernetes [] []
airflow.api_fastapi.core_api.routes.ui.auth [] []
airflow.providers.standard.decorators.sensor [] []
airflow.sdk.definitions.asset.metadata [] []
pygments [] []
airflow.sdk.definitions.connection [] []
airflow.example_dags.example_custom_weight [] []
pyarrow [] []
airflow.providers.standard.triggers.hitl [] []
airflow._shared.observability.metrics.protocols [] []
airflow.exceptions [] []
airflow.providers.standard.operators.bash [] []
airflow._shared.configuration [] []
airflow.sdk.io.store [] []
airflow._shared.observability [] []
airflow.utils [] []
airflow.providers.standard.utils.sensor_helper [] []
airflow.utils.span_status [] []
gevent [] []
airflow.sdk.bases.notifier [] []
airflow.providers.common.compat.lineage.hook [] []
psutil [] []
airflow.utils.log [] []
airflow.ti_deps.deps.not_previously_skipped_dep [] []
airflow.example_dags.tutorial_taskflow_templates [] []
airflow.migrations.versions.0092_3_2_0_replace_deadline_inline_callback_with_fkey [] []
airflow.task.weight_rule [] []
airflow.serialization.definitions.node [] []
sqlalchemy_jsonfield [] []
atheris [] []
airflow.sdk._shared.module_loading [] []
airflow.sdk.bases.operatorlink [] []
airflow.cli [] []
airflow.api_fastapi.execution_api.routes.task_reschedules [] []
airflow.providers.standard [] []
airflow.sdk.observability.metrics.datadog_logger [] []
airflow.sdk.definitions._internal.logging_mixin [] []
airflow.cli.commands.asset_command [] []
airflow.sdk.definitions.timetables._delta [] []
airflow.providers.standard.hooks.filesystem [] []
opentelemetry [] []
airflow.providers.common.compat.openlineage.utils [] []
airflow.api_fastapi.core_api.datamodels.ui.dashboard [] []
airflow.migrations.versions.0015_2_9_0_update_trigger_kwargs_type [] []
airflow.models.dag_favorite [] []
airflow.providers.standard.operators.latest_only [] []
airflow.policies [] []
airflow.api_fastapi.core_api.services.ui.connections [] []
airflow.utils.log.log_reader [] []
airflow.example_dags.example_nested_branch_dag [] []
airflow.executors [] []
airflow._shared.timezones.timezone [] []
airflow._shared.secrets_masker.secrets_masker [] []
airflow.executors.base_executor [] []
airflow.observability.traces [] []
airflow.providers.smtp.hooks [] []
airflow.migrations.utils [] []
airflow.utils.dag_parsing_context [] []
airflow.timetables.assets [] []
airflow.api_fastapi.auth.managers.simple.user [] []
airflow.callbacks [] []
airflow.example_dags.example_xcomargs [] []
airflow.sdk._shared.dagnode.node [] []
airflow.migrations.versions.0062_3_0_0_remove_dag_default_view [] []
airflow.api_fastapi.core_api.datamodels.dag_sources [] []
httpx [] []
airflow.api_fastapi.auth.managers.simple.middleware [] []
airflow.utils.log.non_caching_file_handler [] []
numpy [] []
airflow.sdk.definitions.asset.decorators [] []
airflow.observability.metrics.statsd_logger [] []
airflow.sdk.bases.hook [] []
calendar [] []
airflow.sdk.definitions._internal.dag_parsing_context [] []
airflow.api_fastapi.core_api.datamodels.trigger [] []
io [] []
airflow.providers.common.io [] []
airflow.api_fastapi.core_api.routes.public [] []
sched [] []
aiosmtplib [] []
airflow.providers.standard.example_dags.example_short_circuit_decorator [] []
airflow.api_fastapi.logging.decorators [] []
airflow.sdk._shared.configuration [] []
airflow._shared.logging.structlog [] []
airflow.utils.net [] []
airflow.providers.standard.triggers.temporal [] []
airflow.timetables._delta [] []
airflow.utils.scheduler_health [] []
airflow._shared [] []
airflow._shared.secrets_backend.base [] []
airflow.migrations.versions.0089_3_2_0_add_human_in_the_loop_detail_history [] []
airflow.cli.commands.task_command [] []
airflow.config_templates.default_webserver_config [] []
airflow.migrations.versions.0021_2_10_0_add_task_instance_history [] []
airflow.cli.commands.scheduler_command [] []
airflow.providers.common.io.operators.file_transfer [] []
airflow.example_dags.tutorial_taskflow_api [] []
airflow.providers.common.sql.hooks.sql [] []
base64 [] []
airflow.migrations.versions.0023_2_10_0_dataset_alias_dataset_event [] []
airflow._shared.dagnode.node [] []
airflow.sdk.definitions.asset [] []
requests [] []
airflow.sdk.api.client [] []
airflow.ti_deps.dep_context [] []
airflow.example_dags.standard.example_trigger_controller_dag [] []
airflow.sdk.bases.operator [] []
pygtrie [] []
cadwyn [] []
airflow.providers.standard.operators.smooth [] []
airflow.utils.json [] []
airflow.utils.singleton [] []
airflow.example_dags.example_task_group [] []
airflow.migrations.versions.0032_3_0_0_rename_execution_date_to_logical_date_and_nullable [] []
airflow.sdk.api.datamodels [] []
airflow.migrations.versions.0093_3_2_0_update_orm_asset_partitioning [] []
airflow.utils.dates [] []
airflow.migrations.versions.0022_2_10_0_add_dataset_alias [] []
airflow.api_fastapi.logging [] []
airflow.migrations.versions.0046_3_0_0_drop_dag_pickling [] []
airflow.migrations.versions.0020_2_10_0_added_dagpriorityparsingrequest_table [] []
textwrap [] []
airflow.migrations.versions.0090_3_2_0_add_fail_fast_to_dag_table [] []
airflow.api_fastapi.core_api.routes.public.dag_warning [] []
airflow.api_fastapi.core_api.datamodels.dag_warning [] []
airflow.providers.smtp.notifications [] []
airflow.utils.memray_utils [] []
airflow.api_fastapi.core_api.routes.public.dag_sources [] []
airflow.models.dag [] []
random [] []
airflow.migrations.versions.0045_3_0_0_add_last_heartbeat_at_directly_to_ti [] []
airflow._shared.observability.traces.otel_tracer [] []
airflow.listeners.spec.asset [] []
zlib [] []
airflow.example_dags.standard.example_sensor_decorator [] []
airflow.listeners.spec.taskinstance [] []
airflow.migrations.versions.0052_3_0_0_add_deadline_alerts_table [] []
airflow._shared.module_loading [] []
airflow.providers.standard.sensors.time [] []
airflow.sdk.definitions._internal.templater [] []
airflow.providers.standard.utils.weekday [] []
airflow._shared.observability.traces [] []
airflow.api_fastapi.auth.tokens [] []
airflow.providers.standard.example_dags.example_python_operator [] []
airflow.sdk.serde [] []
airflow.sdk.definitions._internal.setup_teardown [] []
airflow.sdk.io.path [] []
airflow.api_fastapi.core_api.routes.ui.backfills [] []
colorlog.formatter [] []
airflow.observability.trace [] []
airflow.cli.commands.standalone_command [] []
airflow.ti_deps.deps.task_concurrency_dep [] []
airflow.config_templates [] []
airflow.sdk.execution_time.execute_workload [] []
airflow.utils.dag_edges [] []
airflow.utils.serve_logs.core [] []
airflow.providers.common.sql.hooks.handlers [] []
getpass [] []
airflow.models.tasklog [] []
airflow.migrations.versions.0066_3_0_0_rename_dataset_triggered_to_asset_triggered [] []
airflow.sdk._shared.logging [] []
airflow.api_fastapi.core_api.datamodels.log [] []
airflow.sdk.definitions.timetables.simple [] []
airflow.api [] []
airflow.models.errors [] []
tenacity [] []
airflow.dag_processing.bundles.local [] []
airflow.utils.log.action_logger [] []
airflow.providers.standard.example_dags.example_external_task_child_deferrable [] []
airflow.providers.standard.example_dags.example_sensor_decorator [] []
airflow.models.taskinstancekey [] []
airflow.serialization.serializers [] []
croniter [] []
airflow.models.dagrun [] []
airflow.api_fastapi.core_api.datamodels.dag_versions [] []
jinja2 [] []
fcntl [] []
openlineage [] []
airflow.cli.commands.connection_command [] []
airflow.providers.common.compat.sqlalchemy.orm [] []
airflow.example_dags.example_kubernetes_executor [] []
airflow.secrets.environment_variables [] []
yaml [] []
airflow.listeners.spec.dagrun [] []
airflow.providers.standard.operators.hitl [] []
airflow.api_fastapi.core_api [] []
airflow.sdk.definitions.deadline [] []
cron_descriptor [] []
airflow.sdk.definitions [] []
uuid [] []
airflow.api.client.local_client [] []
airflow.sdk.execution_time.sentry.configured [] []
airflow.providers.standard.utils.skipmixin [] []
airflow.sdk.execution_time.sentry.noop [] []
airflow.migrations.versions.0061_3_0_0_use_ti_id_as_primary_key_to_TINote [] []
airflow.sdk.serde.serializers.pandas [] []
airflow.migrations.versions.0094_3_2_0_remove_team_id [] []
airflow.providers.common.compat.openlineage.utils.utils [] []
airflow.models.dag_version [] []
airflow.security.utils [] []
gzip [] []
airflow.serialization.definitions.dag [] []
airflow.sdk.execution_time.hitl [] []
airflow.sdk.exceptions [] []
airflow.sdk.definitions._internal [] []
airflow.migrations.versions.0077_3_1_0_add_trigger_id_to_deadline [] []
airflow.sdk.definitions.timetables._cron [] []
airflow.migrations.versions.0036_3_0_0_add_name_field_to_dataset_model [] []
flask_appbuilder [] []
airflow.providers.standard.decorators.branch_external_python [] []
airflow.api_fastapi.core_api.datamodels.job [] []
airflow.dag_processing.dagbag [] []
airflow.serialization.enums [] []
airflow._shared.configuration.exceptions [] []
airflow.security [] []
airflow.migrations.versions.0016_2_9_2_remove_idx_last_scheduling_decision_ [] []
airflow.providers.common.sql [] []
airflow.utils.types [] []
airflow.example_dags.standard.example_python_operator [] []
airflow.example_dags.example_outlet_event_extra [] []
airflow.migrations.versions.0051_3_0_0_update_task_instance_trigger_timeout_to_utcdatetime [] []
airflow.timetables [] []
airflow.models.backfill [] []
airflow.example_dags.example_passing_params_via_test_command [] []
airflow.sdk.execution_time [] []
airflow.migrations.versions.0033_3_0_0_add_tables_for_backfill [] []
airflow._shared.observability.metrics.statsd_logger [] []
airflow.providers.standard.operators.empty [] []
airflow.cli.cli_parser [] []
airflow.serialization.definitions.baseoperator [] []
airflow.utils.providers_configuration_loader [] []
airflow.callbacks.database_callback_sink [] []
airflow.providers.standard.operators [] []
sqlite3 [] []
airflow.api_fastapi.core_api.datamodels.providers [] []
airflow.timetables._cron [] []
pydantic [] []
airflow.utils.log.file_processor_handler [] []
os [] []
airflow.api_fastapi.execution_api.datamodels.connection [] []
airflow.providers.standard.hooks [] []
airflow.secrets.base_secrets [] []
airflow.providers.common.compat.standard.utils [] []
airflow.migrations.versions.0086_3_2_0_replace_asset_trigger_table_with_asset [] []
airflow.observability.traces.otel_tracer [] []
signal [] []
argcomplete [] []
airflow.providers.standard.sensors.python [] []
airflow.migrations.versions.0028_3_0_0_drop_ab_user_id_foreign_key [] []
sys [] []
json [] []
airflow.api_fastapi.core_api.security [] []
airflow.decorators [] []
airflow.dag_processing.processor [] []
pickle [] []
airflow.executors.executor_constants [] []
airflow.api_fastapi.core_api.routes.ui.connections [] []
tabulate [] []
airflow.sensors [] []
airflow.migrations.versions.0005_2_8_0_add_owner_display_name_to_audit_log_table [] []
airflow.migrations.versions.0072_3_1_0_change_ti_dag_version_fk_to_restrict [] []
airflow.api_fastapi.execution_api [] []
traceback [] []
airflow.serialization.stringify [] []
structlog [] []
airflow.sdk.definitions.timetables.events [] []
airflow.providers.standard.models [] []
hashlib [] []
airflow.migrations.versions.0042_3_0_0_add_uuid_primary_key_to_task_instance_ [] []
airflow.migrations.versions.0001_2_7_0_add_index_to_task_instance_table [] []
airflow._shared.observability.traces.base_tracer [] []
airflow.cli.commands.kerberos_command [] []
airflow.models.referencemixin [] []
airflow.sdk._shared.secrets_backend.base [] []
airflow.api_fastapi.execution_api.datamodels.variable [] []
airflow.serialization.definitions.param [] []
airflow.sdk.api.datamodels._generated [] []
airflow.timetables.datasets [] []
airflow.providers.standard.example_dags [] []
graphviz [] []
airflow.example_dags.standard.example_external_task_child_deferrable [] []
airflow.api_fastapi.core_api.datamodels.variables [] []
airflow.api_fastapi.core_api.routes.public.dag_stats [] []
airflow.api_fastapi.auth [] []
airflow.plugins_manager [] []
airflow.models.xcom [] []
airflow.sdk.bases [] []
airflow.sdk._shared.logging._config [] []
airflow.serialization.definitions [] []
airflow.sdk.definitions._internal.decorators [] []
airflow.providers.standard.decorators.stub [] []
airflow.sdk._shared.secrets_masker.secrets_masker [] []
airflow.migrations.versions.0065_3_0_0_add_new_otel_span_fields [] []
airflow.migrations.versions.0025_2_10_0_dataset_alias_dataset [] []
airflow.jobs.base_job_runner [] []
memray [] []
airflow.sdk._shared.secrets_backend [] []
airflow.migrations.versions.0007_2_8_0_add_processor_subdir_import_error [] []
airflow.utils.dot_renderer [] []
airflow.sdk.definitions.callback [] []
airflow.sdk.definitions.decorators [] []
airflow.listeners [] []
airflow.example_dags [] []
airflow._shared.observability.metrics [] []
airflow.api_fastapi [] []
airflow.providers.common.compat.connection [] []
airflow.typing_compat [] []
airflow.providers.common.sql.operators.generic_transfer [] []
airflow.providers.standard.triggers [] []
airflow.api_fastapi.execution_api.routes [] []
airflow.api_fastapi.core_api.services.public.common [] []
airflow.api_fastapi.common.db.common [] []
airflow.providers.standard.example_dags.example_branch_day_of_week_operator [] []
airflow.example_dags.example_task_group_decorator [] []
airflow.sdk.timezone [] []
airflow.migrations.versions.0030_3_0_0_rename_schedule_interval_to_timetable_ [] []
airflow.providers.common.sql.get_provider_info [] []
airflow.providers.standard.decorators.external_python [] []
airflow.sdk [] []
airflow.migrations.versions.0067_3_0_0_rename_is_active_to_is_stale_column_in_ [] []
airflow.cli.commands.pool_command [] []
airflow.providers.common.compat.notifier [] []
airflow.providers.standard.example_dags.sql [] []
airflow._vendor [] []
airflow.sdk.execution_time.supervisor [] []
airflow.api.common.trigger_dag [] []
airflow.providers.standard.utils [] []
airflow.migrations.versions.0038_3_0_0_add_asset_active [] []
fastapi_cli [] []
airflow.serialization.definitions.mappedoperator [] []
airflow.migrations.versions.0058_3_0_0_add_dagrun_run_after [] []
airflow.utils.session [] []
airflow.providers.common.sql.dialects [] []
airflow.migrations.versions.0041_3_0_0_rename_dataset_as_asset [] []
airflow.providers.common.sql.operators [] []
tempfile [] []
airflow.sdk._shared.observability.metrics.otel_logger [] []
airflow.api_fastapi.core_api.datamodels.event_logs [] []
sentry_sdk [] []
airflow.ti_deps.deps.not_in_retry_period_dep [] []
airflow.sdk.execution_time.timeout [] []
airflow.example_dags.tutorial_dag [] []
airflow.sdk.serde.serializers.datetime [] []
airflow.secrets [] []
airflow.sdk._shared.secrets_masker [] []
airflow.api_fastapi.core_api.datamodels.dag_stats [] []
airflow.ti_deps.deps.dag_ti_slots_available_dep [] []
airflow.sdk._shared.dagnode [] []
airflow.sdk.module_loading [] []
airflow.models.asset [] []
airflow.providers.common.sql.dialects.dialect [] []
airflow.providers.standard.example_dags.example_branch_datetime_operator [] []
airflow.triggers.callback [] []
pyiceberg [] []
airflow.api_fastapi.core_api.routes.public.variables [] []
airflow.providers.smtp.notifications.smtp [] []
airflow.api_fastapi.execution_api.routes.task_instances [] []
airflow.ti_deps.deps.dag_unpaused_dep [] []
airflow.api_fastapi.core_api.routes.ui.assets [] []
airflow.sdk.bases.timetable [] []
airflow.providers.common.io.get_provider_info [] []
setproctitle [] []
socket [] []
airflow.sdk._shared.configuration.parser [] []
airflow.migrations.versions.0091_3_2_0_restructure_callback_table [] []
airflow.api_fastapi.auth.managers.simple [] []
airflow.sdk.definitions.decorators.condition [] []
ast [] []
airflow.migrations.versions.0011_2_9_0_add_dataset_expression_in_dagmodel [] []
airflow.providers.smtp.operators.smtp [] []
airflow.cli.commands.api_server_command [] []
airflow.cli.commands.dag_processor_command [] []
airflow.sdk.execution_time.secrets.execution_api [] []
typing_extensions [] []
daemon [] []
airflow.utils.orm_event_handlers [] []
airflow.api_fastapi.execution_api.routes.xcoms [] []
airflow.migrations.versions [] []
asyncio [] []
airflow.ti_deps.deps.mapped_task_upstream_dep [] []
airflow.api_fastapi.core_api.datamodels.ui.structure [] []
airflow.dag_processing.collection [] []
airflow.utils.log.json_formatter [] []
airflow.utils.event_scheduler [] []
airflow.api_fastapi.core_api.routes.public.dag_tags [] []
airflow.migrations.versions.0068_3_0_0_ti_table_id_unique_per_try [] []
enum [] []
pkgutil [] []
alembic [] []
zipfile [] []
airflow.io [] []
airflow.cli.commands.provider_command [] []
airflow.cli.commands.team_command [] []
airflow.providers.standard.example_dags.example_latest_only [] []
airflow.utils.email [] []
airflow.providers.common.sql.sensors [] []
airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators [] []
airflow.providers.standard.triggers.external_task [] []
airflow.triggers.testing [] []
colorlog.wrappers [] []
airflow.api_fastapi.core_api.datamodels.ui.dag_runs [] []
airflow.sdk.observability.metrics.otel_logger [] []
collections [] []
airflow.models.pool [] []
airflow.sdk.bases.sensor [] []
airflow.providers.common.compat.sdk [] []
airflow.providers.smtp.notifications.templates [] []
airflow.migrations.db_types [] []
airflow.utils.log.task_handler_with_custom_formatter [] []
airflow.sdk.definitions._internal.types [] []
[] []
airflow.triggers [] []
airflow.migrations.versions.0037_3_0_0_add_backfill_to_dag_run_model [] []
airflow.utils.dag_cycle_tester [] []
airflow.providers.common.compat [] []
airflow.ti_deps.deps.runnable_exec_date_dep [] []
termios [] []
airflow.cli.commands.version_command [] []
airflow._shared.observability.exceptions [] []
airflow.api_fastapi.common.db [] []
airflow.api_fastapi.core_api.services.public.dag_run [] []
airflow.sdk.execution_time.context [] []
airflow.datasets [] []
airflow.api_fastapi.auth.managers.models.resource_details [] []
airflow.api_fastapi.core_api.routes.ui.dashboard [] []
airflow.sdk.serde.serializers.kubernetes [] []
airflow.api_fastapi.core_api.datamodels.dags [] []
heapq [] []
airflow.providers.standard.hooks.subprocess [] []
airflow.example_dags.example_dynamic_task_mapping [] []
airflow.providers.standard.decorators.short_circuit [] []
shutil [] []
airflow.api_fastapi.execution_api.versions.v2025_10_27 [] []
airflow.utils.serve_logs.log_server [] []
airflow.utils.strings [] []
inspect [] []
airflow.providers.common.compat._compat_utils [] []
airflow.migrations.versions.0063_3_0_0_use_ti_id_as_fk_to_taskreschedule [] []
airflow.providers.standard.example_dags.example_bash_operator [] []
airflow.migrations.versions.0082_3_1_0_make_bundle_name_not_nullable [] []
zoneinfo [] []
airflow.migrations.versions.0044_3_0_0__drop_task_fail_table [] []
airflow.example_dags.plugins.event_listener [] []
airflow.migrations.versions.0071_3_1_0_rename_and_change_type_of_deadline_column [] []
airflow.migrations.versions.0002_2_7_0_add_custom_operator_name_column [] []
airflow.providers.standard.decorators.python_virtualenv [] []
airflow.models.variable [] []
airflow.api_fastapi.execution_api.versions.v2025_04_28 [] []
smtplib [] []
airflow.example_dags.example_inlet_event_extra [] []
airflow.example_dags.tutorial_taskflow_api_virtualenv [] []
airflow.api.common.delete_dag [] []
airflow.sdk.io.fs [] []
airflow.api_fastapi.core_api.datamodels.monitor [] []
airflow.models.trigger [] []
airflow.providers.standard.decorators.bash [] []
airflow.models.log [] []
airflow.sdk.definitions._internal.node [] []
airflow.sdk.definitions._internal.expandinput [] []
airflow.utils.process_utils [] []
airflow._shared.logging._noncaching [] []
airflow.utils.db [] []
airflow.api_fastapi.common.router [] []
airflow.api_fastapi.core_api.services.ui.calendar [] []
airflow.task.trigger_rule [] []
airflow.utils.helpers [] []
airflow.sdk.yaml [] []
colorlog.escape_codes [] []
airflow.providers.standard.sensors.time_delta [] []
airflow.jobs.dag_processor_job_runner [] []
airflow.example_dags.libs.helper [] []
airflow.providers.smtp.operators [] []
airflow.api_fastapi.core_api.datamodels.ui.auth [] []
airflow.sdk.observability.traces.otel_tracer [] []
airflow.migrations.versions.0088_3_2_0_add_length_dag_bundle_team_bundle_name [] []
airflow.providers.standard.sensors.filesystem [] []
airflow.serialization.definitions.xcom_arg [] []
airflow.sdk.log [] []
airflow._shared.observability.metrics.datadog_logger [] []
airflow.api_fastapi.core_api.services.ui.dependencies [] []
airflow.lineage.hook [] []
airflow.providers.common.compat.sqlalchemy [] []
airflow.providers.common.sql.operators.sql [] []
airflow.utils.log.colored_log [] []
airflow.dag_processing.bundles.base [] []
pluggy [] []
airflow.migrations.env [] []
airflow.migrations.versions.0060_3_0_0_add_try_id_to_ti_and_tih [] []
airflow.sdk.api.datamodels.activities [] []
airflow.providers.common.io.assets.assets [] []
airflow.assets [] []
airflow.sdk._shared.observability.metrics.protocols [] []
lazy_object_proxy [] []
airflow.sdk._shared.observability.traces [] []
airflow.example_dags.example_branch_python_dop_operator_3 [] []
airflow.api_fastapi.auth.managers.simple.datamodels [] []
airflow.models.serialized_dag [] []
importlib_metadata [] []
certifi [] []
airflow.cli.commands.dag_command [] []
airflow.api_fastapi.auth.managers.base_auth_manager [] []
airflow.api_fastapi.core_api.openapi.exceptions [] []
airflow.sdk._shared.timezones.timezone [] []
airflow.migrations.versions.0075_3_1_0_add_dag_favorite_table [] []
airflow.api_fastapi.core_api.services.public.task_instances [] []
airflow.models.skipmixin [] []
airflow.example_dags.example_asset_alias [] []
airflow.cli.hot_reload [] []
airflow.providers.standard.operators.python ['dag_fuzz'] []
airflow.api_fastapi.core_api.datamodels.ui.common [] []
airflow.ti_deps.deps.ready_to_reschedule [] []
airflow.cli.commands.variable_command [] []
airflow.migrations.versions.0000_2_6_2_squashed_migrations [] []
airflow.models.xcom_arg [] []
airflow.sdk.execution_time.cache [] []
airflow.api_fastapi.execution_api.versions.v2025_08_10 [] []
airflow.ti_deps.deps.pool_slots_available_dep [] []
airflow.api_fastapi.execution_api.routes.dag_runs [] []
airflow.api_fastapi.core_api.services.public [] []
re [] []
airflow.api_fastapi.core_api.routes.ui.dags [] []
airflow.api_fastapi.core_api.datamodels.ui [] []
airflow.example_dags.plugins.decreasing_priority_weight_strategy [] []
airflow.providers.standard.example_dags.example_python_decorator [] []
airflow.api_fastapi.auth.managers.simple.services.login [] []
airflow.migrations.versions.0040_3_0_0_add_exception_reason_and_logical_date_ [] []
methodtools [] []
airflow.config_templates.airflow_local_settings [] []
airflow.migrations [] []
airflow.api_fastapi.core_api.datamodels.ui.dags [] []
airflow.migrations.versions.0013_2_9_0_make_xcom_value_to_longblob_for_mysql [] []
airflow.providers.standard.decorators.python [] []
urllib [] []
airflow.example_dags.example_xcom [] []
airflow.hooks.base [] []
msal [] []
airflow.migrations.versions.0024_2_10_0_add_try_number_to_audit_log [] []
airflow.migrations.versions.0081_3_1_0_remove_dag_id_from_deadline [] []
argparse [] []
airflow.sdk.io.typedef [] []
airflow.ti_deps.deps.dagrun_exists_dep [] []
airflow.migrations.versions.0019_2_10_0_add_new_executor_field_to_db [] []
airflow.sdk._shared.observability [] []
airflow.cli.simple_table [] []
airflow.sdk.definitions._internal.contextmanager [] []
rich_argparse [] []
airflow.executors.executor_utils [] []
airflow.api_fastapi.auth.managers.simple.routes.login [] []
airflow.providers.standard.example_dags.example_hitl_operator [] []
airflow.example_dags.example_params_trigger_ui [] []
airflow.api_fastapi.core_api.datamodels.dag_tags [] []
airflow.sdk.execution_time.callback_runner [] []
airflow.api_fastapi.core_api.routes.public.extra_links [] []
airflow.api_fastapi.core_api.routes.ui.config [] []
time [] []
airflow.models.hitl [] []
airflow.api_fastapi.core_api.datamodels.import_error [] []
airflow._shared.timezones [] []
airflow._shared.observability.metrics.otel_logger [] []
decimal [] []
airflow.callbacks.base_callback_sink [] []
airflow.ti_deps.dependencies_deps [] []
airflow.migrations.versions.0064_3_0_0_support_bundles_in_ [] []
airflow.sdk.definitions.context [] []
airflow.api_fastapi.core_api.routes.ui.dependencies [] []
airflow.migrations.versions.0049_3_0_0_remove_pickled_data_from_xcom_table [] []
airflow.utils.edgemodifier [] []
atexit [] []
airflow.sdk.serde.serializers.builtin [] []
airflow.observability.metrics.datadog_logger [] []
airflow.example_dags.example_trigger_target_dag [] []
airflow.api_fastapi.execution_api.datamodels.token [] []
airflow.api_fastapi.execution_api.datamodels.asset_event [] []
airflow.sdk.serde.serializers.numpy [] []
airflow.sdk.execution_time.macros [] []
statsd [] []
airflow.api_fastapi.execution_api.app [] []
airflow.migrations.versions.0043_3_0_0_remove_scheduler_lock_column [] []
airflow.models.dagcode [] []
airflow.providers.standard.example_dags.example_short_circuit_operator [] []
airflow.migrations.versions.0048_3_0_0_add_trigger_asset_reference [] []
airflow._shared.logging.percent_formatter [] []
airflow.sdk.configuration [] []
airflow.utils.thread_safe_dict [] []
itsdangerous [] []
airflow.api_fastapi.core_api.routes.ui.calendar [] []
airflow.dag_processing [] []
airflow.providers.standard.sensors.weekday [] []
airflow.api_fastapi.core_api.routes.public.connections [] []
airflow.logging_config [] []
airflow.migrations.versions.0059_3_0_0_remove_external_trigger_field [] []
airflow.timetables.interval [] []
airflow.api_fastapi.core_api.services.ui.task_group [] []
email [] []
gc [] []
airflow.api_fastapi.core_api.routes.ui [] []
airflow.observability [] []
airflow.dag_processing.bundles.manager [] []
airflow.api_fastapi.execution_api.datamodels [] []
airflow.example_dags.standard.example_external_task_marker_dag [] []
contextlib [] []
airflow.api_fastapi.common.exceptions [] []
airflow.sdk._shared.observability.traces.otel_tracer [] []
airflow.example_dags.standard.example_sensors [] []
airflow.api_fastapi.core_api.app [] []
airflow.providers.common.sql.version_compat [] []
operator [] []
airflow.api_fastapi.core_api.routes.public.dag_run [] []
airflow.api_fastapi.common.db.dags [] []
airflow.providers.common.compat.security [] []
greenback [] []
airflow.api_fastapi.execution_api.datamodels.taskinstance [] []
airflow.models.db_callback_request [] []
airflow.example_dags.example_asset_decorator [] []
airflow.api_fastapi.core_api.datamodels.dag_run [] []
watchfiles [] []
airflow.example_dags.example_asset_alias_with_no_taskflow [] []
airflow.cli.commands.plugins_command [] []
airflow.api_fastapi.execution_api.datamodels.dagrun [] []
airflow.cli.commands.config_command [] []
airflow.api_fastapi.core_api.datamodels.task_instances [] []
airflow.sdk.api [] []
attrs [] []
airflow._shared.secrets_masker [] []
airflow.api_fastapi.core_api.services.public.variables [] []
http [] []
airflow.api_fastapi.core_api.routes.public.task_instances [] []
glob [] []
airflow.api_fastapi.app [] []
typing [] []
airflow.api.client [] []
airflow.migrations.versions.0018_2_10_0_add_indexes_on_dag_id_column_in_referencing_tables [] []
airflow.models.hitl_history [] []
airflow.example_dags.example_display_name [] []
airflow.api_fastapi.execution_api.routes.hitl [] []
airflow.sdk.definitions.timetables.interval [] []
airflow.providers.common.compat.lineage.entities [] []
airflow.utils.sqlalchemy [] []
airflow.sdk._shared.timezones [] []
airflow.api.common [] []
airflow.sdk._shared.observability.metrics.datadog_logger [] []
html [] []
airflow.sdk.definitions._internal.abstractoperator [] []
airflow.api_fastapi.execution_api.deps [] []
airflow.models.crypto [] []
flask_babel [] []
locale [] []
airflow.providers.common.io.xcom.backend [] []
airflow.api_fastapi.core_api.routes.public.assets [] []
airflow.sdk._shared.observability.traces.utils [] []
airflow.models.base [] []
airflow.api_fastapi.common.db.dag_runs [] []
airflow.sdk.serde.serializers [] []
airflow.providers.standard.triggers.file [] []
sqlalchemy [] []
airflow.migrations.versions.0010_2_9_0_add_run_id_to_audit_log_table_and_change_event_name_length [] []
math [] []
airflow.observability.stats [] []
airflow.api_fastapi.core_api.routes.public.dag_versions [] []
airflow.sdk.definitions.timetables.assets [] []
airflow.jobs [] []
airflow.sdk.definitions.xcom_arg [] []
airflow.sdk.definitions.mappedoperator [] []
airflow.dag_processing.manager [] []
airflow.api_fastapi.execution_api.routes.variables [] []
airflow.api_fastapi.auth.managers [] []
airflow.api_fastapi.common.dagbag [] []
airflow.assets.evaluation [] []
airflow.migrations.versions.0070_3_1_0_add_deadline_to_dag [] []
types [] []
airflow.serialization.definitions.assets [] []
airflow.api_fastapi.core_api.routes.ui.structure [] []
tracemalloc [] []
airflow.sdk.observability [] []
airflow.cli.commands.cheat_sheet_command [] []
airflow.cli.cli_config [] []
airflow.api_fastapi.execution_api.versions.v2025_09_23 [] []
airflow.sdk.execution_time.task_runner [] []
airflow.sdk.definitions._internal.mixins [] []
airflow.sdk.definitions.template [] []
airflow.sdk.observability.traces [] []
airflow.executors.local_executor [] []
airflow.observability.metrics [] []
airflow.api_fastapi.core_api.datamodels.hitl [] []
a2wsgi [] []
airflow.cli.commands.triggerer_command [] []
tty [] []
airflow.security.permissions [] []
airflow._shared.configuration.parser [] []
pprint [] []
airflow.api_fastapi.core_api.services.public.connections [] []
airflow.api_fastapi.execution_api.datamodels.asset [] []
airflow.example_dags.example_branch_labels [] []
airflow.utils.log.log_stream_accumulator [] []
airflow.example_dags.standard.example_bash_decorator [] []
attr [] []
airflow.providers.common.compat.openlineage [] []
airflow._shared.dagnode [] []
airflow.timetables.simple [] []
airflow.api_fastapi.core_api.services [] []
airflow.sdk.observability.metrics.statsd_logger [] []
airflow.utils.hashlib_wrapper [] []
airflow.api_fastapi.auth.managers.simple.utils [] []
airflow.api_fastapi.core_api.routes.public.version [] []
airflow.example_dags.tutorial_objectstorage [] []
airflow.api_fastapi.core_api.datamodels.ui.calendar [] []
airflow.example_dags.standard.example_branch_operator [] []
airflow.api_fastapi.common [] []
airflow.example_dags.example_setup_teardown [] []
airflow.version [] []
airflow.observability.metrics.otel_logger [] []
airflow.migrations.versions.0012_2_9_0_adding_adding_max_failure_runs_column_ [] []
uvicorn [] []
airflow.migrations.versions.0057_3_0_0_add_new_task_instance_field_scheduled_ [] []
airflow.ti_deps.deps.prev_dagrun_dep [] []
airflow.sdk.definitions.param [] []
airflow.timetables.events [] []
abc [] []
airflow.sdk._shared.observability.traces.base_tracer [] []
airflow.migrations.versions.0029_3_0_0_remove_is_subdag [] []
airflow.dag_processing.bundles [] []
airflow.listeners.listener [] []
airflow.api_fastapi.core_api.datamodels.ui.config [] []
airflow.providers.standard.sensors.external_task [] []
airflow.api_fastapi.core_api.routes.public.import_error [] []
weakref [] []
airflow.ti_deps.deps [] []
msgspec [] []
airflow.utils.yaml [] []
airflow.example_dags.plugins.listener_plugin [] []
airflow.sdk.definitions.decorators.setup_teardown [] []
natsort [] []
airflow.api_fastapi.core_api.datamodels.version [] []
airflow.providers.common.compat.openlineage.utils.sql [] []
select [] []
jwt [] []
airflow.example_dags.example_dag_decorator [] []
airflow.providers.common.compat.standard.triggers [] []
dateutil [] []
airflow.models.team [] []
uuid6 [] []
airflow.example_dags.plugins.workday [] []
airflow.providers.common.compat.standard [] []
airflow.sdk.types [] []
airflow.api_fastapi.core_api.routes.public.hitl [] []
airflow.example_dags.standard.example_short_circuit_decorator [] []

Directories in report

Directory

Metadata section

This sections shows the raw data that is used to produce this report. This is mainly used for further processing and developer debugging.

Fuzzer Calltree file Program data file Coverage file
dag_fuzz fuzzerLogFile-dag_fuzz.data fuzzerLogFile-dag_fuzz.data.yaml all_cov.json