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

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

Call tree overview bitmap:

The distribution of callsites in terms of coloring is
Color Runtime hitcount Callsite count Percentage
red 0 68 49.2%
gold [1:9] 0 0.0%
yellow [10:29] 0 0.0%
greenyellow [30:49] 0 0.0%
lawngreen 50+ 70 50.7%
All colors 138 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
11 87 airflow.models.dag.DAG.__init__ call site: 00087 airflow.models.dag.DAG.get_template_env
7 25 airflow.models.param.ParamsDict.__init__ call site: 00025 airflow.models.param.Param.__init__
6 12 ...dag_fuzz.TestInput call site: 00012 airflow.models.dag.DAG.__init__
6 103 airflow.utils.task_group.TaskGroup.__init__ call site: 00103 airflow.utils.helpers.validate_group_key
6 111 airflow.utils.task_group.TaskGroup.__init__ call site: 00111 airflow.utils.task_group.TaskGroup.add
5 62 airflow.models.dag.DAG.__init__ call site: 00062 airflow.timetables.interval.DeltaDataIntervalTimetable.__init__
5 132 airflow.models.dag.DAG.__init__ call site: 00132 fdp.ConsumeString
3 55 airflow.models.dag.DAG.__init__ call site: 00055 .isinstance
3 83 airflow.models.dag.DAG.__init__ call site: 00083 access_control.items
2 42 airflow.models.dag.DAG.__init__ call site: 00042 .isinstance
1 0 EP call site: 00000 atheris.FuzzedDataProvider
1 10 airflow.utils.dates.days_ago call site: 00010 fdp.ConsumeString

Runtime coverage analysis

Covered functions
710
Functions that are reachable but not covered
64
Reachable functions
85
Percentage of reachable functions covered
24.71%
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 9
airflow.utils.dates 3
airflow.utils.timezone 2
airflow.models.dag 43
airflow.models.param 8
airflow.utils.helpers 6
airflow.timetables._cron 7
airflow.utils.task_group 16

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'] 13 0 8 3 4 2761 0 9139 8876
airflow.www.decorators.action_logging.log_action.wrapper airflow.www.decorators 2 ['N/A', 'N/A'] 13 0 2 4 5 2441 0 8099 208
airflow.api_connexion.endpoints.config_endpoint.get_config airflow.api_connexion.endpoints.config_endpoint 1 ['N/A'] 10 0 2 4 5 91 0 319 137
airflow.utils.log.file_task_handler.FileTaskHandler.read airflow.utils.log.file_task_handler 4 ['N/A', 'N/A', 'N/A', 'N/A'] 5 0 1 2 4 159 0 503 124
airflow.www.fab_security.manager.BaseSecurityManager.auth_user_ldap airflow.www.fab_security.manager 3 ['N/A', 'N/A', 'N/A'] 2 0 28 27 14 43 0 147 108
airflow.www.views.Airflow.index airflow.www.views 1 ['N/A'] 2 0 5 20 11 96 0 302 105
airflow.sensors.base.BaseSensorOperator.execute airflow.sensors.base 2 ['N/A', 'N/A'] 10 0 3 9 7 252 0 827 95

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

Functions statically reachable by fuzzers
32.0%
1303 / 4104
Cyclomatic complexity statically reachable by fuzzers
34.0%
4836 / 14036

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 Fuzzers runtime hit Func lines hit % I Count BB Count Cyclomatic complexity Functions reached Reached by functions Accumulated cyclomatic complexity Undiscovered complexity

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
airflow.utils.dates.date_range 46 0 0.0% []
airflow.models.dag.DAG._get_task_instances 88 0 0.0% []
airflow.models.dag.DAG.set_task_group_state 35 0 0.0% []
airflow.models.dag.DAG.partial_subset.filter_task_group 33 0 0.0% []
airflow.models.dag.DAG.create_dagrun 36 1 2.777% []
airflow.models.dag.DAG.bulk_write_to_db 130 0 0.0% []
os.system 155 30 19.35% []
name.startswith 67 13 19.40% []
airflow.configuration.AirflowConfigParser.get 36 18 50.0% []
airflow.configuration.initialize_config 39 21 53.84% []
h.flush 55 16 29.09% []
typing_extensions.get_type_hints 1061 419 39.49% []
old.search 256 100 39.06% []
cryptography.fernet.MultiFernet 137 36 26.27% []
airflow.models.abstractoperator.AbstractOperator.expand_mapped_task 50 0 0.0% []
airflow.utils.task_group.TaskGroup.__init__ 40 21 52.5% ['dag_fuzz']
airflow.models.taskinstance.clear_task_instances 48 0 0.0% []
airflow.models.taskinstance.TaskInstance.refresh_from_db 33 0 0.0% []
airflow.models.taskinstance.TaskInstance.check_and_change_state_before_execution 46 0 0.0% []
airflow.models.taskinstance.TaskInstance._run_raw_task 76 0 0.0% []
airflow.models.taskinstance.TaskInstance._execute_task 33 0 0.0% []
airflow.models.taskinstance.TaskInstance.handle_failure 54 0 0.0% []
airflow.models.taskinstance.TaskInstance.filter_for_tis 38 2 5.263% []
airflow.models.dagbag.DagBag.get_dag 39 0 0.0% []
airflow.models.dagbag.DagBag._load_modules_from_zip 35 0 0.0% []
airflow.models.dagbag.DagBag._bag_dag 31 0 0.0% []
airflow.models.xcom.BaseXCom.get_many 36 1 2.777% []
airflow.models.dagrun.DagRun.update_state._UnfinishedStates.recalculate 57 0 0.0% []
airflow.models.dagrun.DagRun._get_ready_tis._expand_mapped_task_if_needed 35 0 0.0% []
airflow.models.dagrun.DagRun._check_for_removed_or_restored_tasks 50 4 8.0% []
airflow.config_templates.airflow_local_settings 73 29 39.72% []
result.append 32 13 40.62% []
airflow.utils.operator_helpers.context_to_airflow_vars 34 2 5.882% []
f.flush 78 21 26.92% []
airflow.utils.email.send_mime_email 40 0 0.0% []
query.options 726 299 41.18% []
copy.copy.set_context 79 42 53.16% []
source._deprecation_replacements.copy 613 39 6.362% []
pendulum.parsing.parse_iso8601.utcoffset 104 23 22.11% []
op.has_dag 33 10 30.30% []
airflow.utils.setup_teardown.SetupTeardownContext.push_setup_teardown_task 41 0 0.0% []
airflow.utils.setup_teardown.SetupTeardownContext.set_work_task_roots_and_leaves 33 0 0.0% []
airflow.ti_deps.deps.prev_dagrun_dep.PrevDagrunDep._get_dep_statuses 44 0 0.0% []
airflow.models.skipmixin.SkipMixin.skip_all_except 31 0 0.0% []
pendulum.tz.timezone.Timezone 211 70 33.17% ['dag_fuzz']
pendulum.tz.local_timezone 152 28 18.42% []
rich.console.Console.export_text 989 470 47.52% []
cursor.keys 699 203 29.04% []
k.lower 164 30 18.29% []
delta.total_seconds 242 36 14.87% []
jinja2.nativetypes.NativeEnvironment 68 30 44.11% []
message.center 94 48 51.06% []
airflow.utils.log.file_task_handler.FileTaskHandler._read 35 0 0.0% []
pendulum.datetime.DateTime.utcnow 494 169 34.21% []
response.raise_for_status 562 133 23.66% []
io.StringIO 74 15 20.27% []
x.name.decode 154 45 29.22% []
airflow.serialization.serde.serialize 40 0 0.0% []
airflow.serialization.serde.deserialize 43 0 0.0% []
o.attach_to_pod 37 16 43.24% []
jinja2.sandbox.is_internal_attribute 153 52 33.98% []
tabulate.tabulate 797 118 14.80% []
textwrap.indent 44 12 27.27% []
pattern.rstrip 44 18 40.90% []
pathspec.patterns.GitWildMatchPattern 70 25 35.71% []
metadata.get 442 220 49.77% []
url.get_backend_name 239 95 39.74% []
flask.helpers.flash 145 45 31.03% []
markupsafe.Markup.striptags 162 78 48.14% []
packaging.version.Version 162 20 12.34% []
flask.json.provider.JSONProvider.__init__ 104 31 29.80% []
airflow.utils.process_utils.reap_process_group.signal_procs 51 0 0.0% []
psutil.pid_exists 946 247 26.10% []
tty.setraw 396 85 21.46% []
lockfile.pidlockfile.remove_existing_pidfile 42 11 26.19% []
connection.begin 70 18 25.71% []
werkzeug.security.check_password_hash 51 15 29.41% []
app.config.get 697 207 29.69% []
flask.json.jsonify 65 21 32.30% []
jinja2.utils.htmlsafe_json_dumps 315 115 36.50% []
croniter.croniter.get_prev 577 173 29.98% []
date.isoformat 272 95 34.92% []
row.values 209 89 42.58% []
queue.SimpleQueue 135 45 33.33% []
flask_sqlalchemy.SQLAlchemy.drop_all 562 136 24.19% []
c.label 93 10 10.75% []
rich.table.Table.add_row 393 83 21.11% []
z.infolist 34 12 35.29% []
runtime.total_seconds 494 179 36.23% []
cron_descriptor.ExpressionDescriptor.get_description 254 109 42.91% ['dag_fuzz']
parser.error 252 43 17.06% []
airflow.ti_deps.deps.trigger_rule_dep.TriggerRuleDep._evaluate_trigger_rule._iter_upstream_conditions 124 0 0.0% []
attributes.items 858 281 32.75% []
opentelemetry.exporter.otlp.proto.http.metric_exporter.OTLPMetricExporter 172 46 26.74% []
opentelemetry.sdk.metrics._internal.export.ConsoleMetricExporter 181 63 34.80% []
sql.strip 55 24 43.63% []
flask.sessions.SecureCookieSessionInterface.__init__ 141 61 43.26% []
auth.requires_authentication 178 37 20.78% []
rich.print 35 15 42.85% []
compiler.process 1182 365 30.87% []
options.items 652 163 25.0% []
http.server.HTTPServer.serve_forever 466 94 20.17% []
pendulum.time 105 32 30.47% []
itsdangerous.url_safe.URLSafeSerializer.dumps 41 17 41.46% []
i.strip 195 14 7.179% []
serializer.keys 109 35 32.11% []

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
[] []
jwt [] []
airflow.migrations.versions.0026_1_8_2_increase_text_size_for_mysql [] []
airflow.cli.commands.role_command [] []
flask_openid [] []
airflow.migrations.versions.0042_1_10_3_task_reschedule_fk_on_cascade_delete [] []
airflow.providers.ftp.hooks.ftp [] []
airflow.models.xcom [] []
airflow.contrib.sensors [] []
airflow.metrics.protocols [] []
airflow.callbacks.callback_requests [] []
airflow.migrations.versions.0092_2_2_0_add_data_interval_start_end_to_dagmodel_and_dagrun [] []
connexion [] []
airflow.cli.commands.task_command [] []
airflow.utils.dag_parsing_context [] []
airflow.api.common.experimental.get_code [] []
airflow.utils.dag_edges [] []
airflow.example_dags.tutorial_taskflow_api [] []
airflow.api_connexion.schemas.pool_schema [] []
cryptography [] []
airflow.migrations.versions.0068_2_0_0_drop_kuberesourceversion_and_ [] []
airflow.serialization.json_schema [] []
airflow.example_dags.example_latest_only [] []
jsonschema [] []
airflow.lineage [] []
airflow.ti_deps.deps.base_ti_dep [] []
airflow.ti_deps.deps.task_not_running_dep [] []
werkzeug [] []
airflow.cli.commands.scheduler_command [] []
airflow.migrations.versions.0080_2_0_2_change_default_pool_slots_to_1 [] []
airflow.migrations.versions.0048_1_10_3_remove_dag_stat_table [] []
airflow.example_dags.subdags.subdag [] []
airflow.cli.simple_table [] []
airflow.utils.compression [] []
airflow.api_connexion.endpoints.role_and_permission_endpoint [] []
airflow.migrations.versions.0117_2_4_0_add_processor_subdir_to_dagmodel_and_ [] []
airflow.api_connexion.schemas.plugin_schema [] []
airflow.api_connexion.schemas.enum_schemas [] []
airflow.api_connexion.exceptions [] []
airflow.jobs.dag_processor_job_runner [] []
airflow.utils.log.logging_mixin [] []
airflow.utils.serve_logs [] []
airflow.example_dags.example_kubernetes_executor [] []
airflow.example_dags.example_sensors [] []
airflow.decorators.python [] []
airflow.utils.helpers ['dag_fuzz'] []
fnmatch [] []
tempfile [] []
concurrent [] []
airflow.migrations.versions.0071_2_0_0_add_job_id_to_dagrun_table [] []
airflow.www.auth [] []
typing_extensions [] []
bz2 [] []
airflow.models.renderedtifields [] []
airflow.decorators.external_python [] []
airflow.kubernetes.pod_generator_deprecated [] []
airflow.models.taskmap [] []
airflow.task.task_runner.cgroup_task_runner [] []
attr [] []
wtforms [] []
airflow.example_dags.example_branch_datetime_operator [] []
airflow.example_dags.example_dynamic_task_mapping [] []
airflow.migrations.versions.0122_2_5_0_add_is_orphaned_to_datasetmodel [] []
airflow.utils.code_utils [] []
uuid [] []
airflow.utils.log.file_processor_handler [] []
airflow.providers.ftp.operators.ftp [] []
airflow.providers.ftp.sensors [] []
airflow.security.utils [] []
airflow.migrations.versions.0123_2_6_0_add_dttm_index_on_log_table [] []
airflow.cli.commands.webserver_command [] []
airflow.migrations.versions.0112_2_4_0_add_dagwarning_model [] []
airflow.datasets [] []
airflow.migrations.versions.0094_2_2_3_add_has_import_errors_column_to_dagmodel [] []
airflow.security.permissions [] []
airflow.utils.log.timezone_aware [] []
airflow.utils.weight_rule [] []
sentry_sdk [] []
airflow.models.mappedoperator [] []
airflow.listeners.spec.taskinstance [] []
airflow.__main__ [] []
airflow.ti_deps.deps [] []
airflow.api_connexion.schemas.role_and_permission_schema [] []
shlex [] []
airflow.www.validators [] []
airflow.models.tasklog [] []
colorlog [] []
airflow.example_dags.example_setup_teardown_taskflow [] []
airflow.migrations.versions.0108_2_3_0_default_dag_view_grid [] []
airflow.providers.http.hooks.http [] []
airflow.timetables._cron ['dag_fuzz'] []
airflow.providers.imap.hooks.imap [] []
airflow.models.dagwarning [] []
airflow.api_connexion.schemas.user_schema [] []
airflow.utils.docs [] []
airflow.executors.sequential_executor [] []
airflow.ti_deps.deps.exec_date_after_start_date_dep [] []
airflow.utils.scheduler_health [] []
airflow.example_dags.tutorial_taskflow_api_virtualenv [] []
airflow.example_dags.example_python_operator [] []
airflow.example_dags.subdags [] []
airflow.cli.commands.legacy_commands [] []
airflow.migrations.versions.0090_2_2_0_rename_concurrency_column_in_dag_table_ [] []
airflow.models.skipmixin [] []
airflow.executors.dask_executor [] []
airflow.api_connexion.endpoints.dag_endpoint [] []
atexit [] []
airflow.ti_deps.deps.ready_to_reschedule [] []
airflow.utils.weekday [] []
airflow.migrations.versions.0119_2_4_3_add_case_insensitive_unique_constraint_for_username [] []
tty [] []
airflow.api.common.experimental.trigger_dag [] []
airflow.providers.imap.get_provider_info [] []
airflow.api.common.experimental.mark_tasks [] []
airflow.executors.local_kubernetes_executor [] []
airflow.utils.retries [] []
airflow.api_connexion.schemas.dataset_schema [] []
airflow.migrations.versions.0103_2_3_0_add_callback_request_table [] []
airflow.api.common.delete_dag [] []
airflow.ti_deps.dependencies_deps [] []
airflow.executors.celery_executor_utils [] []
airflow.serialization.pydantic.dag_run [] []
airflow.serialization.serializers.datetime [] []
airflow.api.auth.backend.basic_auth [] []
contextvars [] []
airflow.utils.log.file_task_handler [] []
markdown_it [] []
airflow.migrations.versions.0046_1_10_5_change_datetime_to_datetime2_6_on_mssql_ [] []
airflow.example_dags.example_params_trigger_ui [] []
types [] []
airflow.migrations.versions.0062_2_0_0_add_dagrun_run_type [] []
airflow.operators.python [] []
airflow.models.taskfail [] []
airflow.utils.dag_cycle_tester [] []
signal [] []
airflow.operators.empty [] []
airflow.executors.kubernetes_executor [] []
airflow.providers.http.operators [] []
airflow.migrations.versions.0067_2_0_0_add_external_executor_id_to_ti [] []
airflow.cli.commands.rotate_fernet_key_command [] []
airflow.providers.common.sql.hooks.sql [] []
airflow.migrations.versions.0081_2_0_2_rename_last_scheduler_run_column [] []
airflow.utils.cli [] []
airflow.kubernetes.k8s_model [] []
termcolor [] []
airflow.kubernetes.volume_mount [] []
airflow.example_dags.example_time_delta_sensor_async [] []
airflow.cli.commands.version_command [] []
airflow.api_connexion.schemas.version_schema [] []
airflow.version [] []
airflow.triggers.base [] []
lazy_object_proxy [] []
airflow.models.pool [] []
airflow.migrations.versions.0057_1_10_13_add_fab_tables [] []
airflow._vendor [] []
airflow.migrations.versions.0008_1_6_0_task_duration [] []
airflow.cli.commands.triggerer_command [] []
airflow.kubernetes.kube_config [] []
opentelemetry [] []
airflow.triggers.temporal [] []
airflow.api_connexion.schemas.task_instance_schema [] []
airflow.utils.trigger_rule [] []
croniter [] []
flask [] []
airflow.kubernetes [] []
airflow.kubernetes.pod_launcher [] []
inspect [] []
airflow.utils.setup_teardown [] []
airflow.cli.commands.cheat_sheet_command [] []
tenacity [] []
airflow.www.extensions.init_security [] []
select [] []
airflow.example_dags.plugins.listener_plugin [] []
jmespath [] []
airflow.decorators.branch_python [] []
airflow.example_dags.example_bash_operator [] []
airflow.api_connexion.schemas.health_schema [] []
airflow.template [] []
airflow.config_templates [] []
airflow.api_connexion.schemas.sla_miss_schema [] []
marshmallow_sqlalchemy [] []
atheris [] []
shutil [] []
airflow.api_connexion.endpoints.dag_warning_endpoint [] []
airflow.callbacks.pipe_callback_sink [] []
airflow.operators [] []
configparser [] []
airflow.api.auth.backend [] []
airflow.migrations.versions.0098_2_3_0_added_timetable_description_column [] []
imaplib [] []
airflow.api.common.experimental.get_task_instance [] []
airflow.migrations.versions.0003_1_5_0_for_compatibility [] []
airflow.api_internal.endpoints.rpc_api_endpoint [] []
airflow.migrations.versions.0096_2_2_4_adding_index_for_dag_id_in_job [] []
airflow.api.common.experimental.pool [] []
airflow.listeners.spec.dagrun [] []
airflow.migrations.versions.0069_2_0_0_add_scheduling_decision_to_dagrun_and_ [] []
airflow.sensors.python [] []
tabulate [] []
airflow.www.fab_security [] []
airflow.example_dags.example_subdag_operator [] []
airflow.security.kerberos [] []
weakref [] []
airflow.providers.sqlite.get_provider_info [] []
sqlalchemy_jsonfield [] []
platform [] []
airflow.api_connexion.schemas.job_schema [] []
airflow.api_connexion.endpoints [] []
airflow.www.blueprints [] []
airflow.migrations.versions.0020_1_7_1_xcom_dag_task_indices [] []
airflow.contrib.task_runner [] []
airflow.secrets.base_secrets [] []
airflow.migrations.versions.0047_1_10_4_increase_queue_name_size_limit [] []
locale [] []
colorlog.colorlog [] []
airflow.example_dags.plugins [] []
airflow.migrations.versions.0036_1_10_2_add_index_to_taskinstance [] []
airflow.ti_deps.deps.pool_slots_available_dep [] []
airflow.migrations.versions.0124_2_6_0_increase_length_of_user_identifier_columns [] []
airflow.kubernetes.pod_runtime_info_env [] []
airflow.listeners.spec [] []
airflow.cli.commands.dag_command [] []
airflow.listeners [] []
airflow.api_connexion [] []
airflow.example_dags.example_external_task_marker_dag [] []
airflow.operators.email [] []
airflow.migrations.versions.0006_1_6_0_adding_extra_to_log [] []
airflow.migrations.versions.0035_1_10_2_add_idx_log_dag [] []
flask_babel [] []
airflow.models.crypto [] []
airflow.utils.log.action_logger [] []
statsd [] []
airflow.serialization.serde [] []
airflow.api_connexion.endpoints.health_endpoint [] []
airflow.providers.http.sensors.http [] []
airflow.providers.common.sql.sensors.sql [] []
struct [] []
airflow.migrations.versions.0043_1_10_4_make_taskinstance_pool_not_nullable [] []
contextlib [] []
airflow.dag_processing.manager [] []
airflow.migrations.versions [] []
airflow.api.common.airflow_health [] []
airflow.migrations.versions.0011_1_6_2_dagrun_start_end [] []
airflow.api_connexion.schemas.config_schema [] []
airflow.task.task_runner.standard_task_runner [] []
airflow.utils.context [] []
airflow.jobs.job [] []
airflow.www.widgets [] []
airflow.migrations.versions.0076_2_0_0_fix_description_field_in_connection_to_ [] []
airflow.ti_deps.deps.task_concurrency_dep [] []
airflow.api_connexion.schemas.log_schema [] []
airflow.migrations.versions.0066_2_0_0_add_queued_by_job_id_to_ti [] []
airflow.www.extensions [] []
airflow_local_settings [] []
http [] []
airflow.migrations.versions.0075_2_0_0_add_description_field_to_connection [] []
airflow.www.fab_security.views [] []
asyncio [] []
airflow.providers.common.sql [] []
airflow.operators.weekday [] []
airflow.utils.operator_resources [] []
airflow.utils.python_virtualenv [] []
airflow.migrations.versions.0037_1_10_2_add_task_reschedule_table [] []
airflow.secrets [] []
airflow.timetables [] []
airflow.migrations.versions.0034_1_10_0_index_taskfail [] []
airflow.ti_deps.dependencies_states [] []
airflow.utils.decorators [] []
textwrap [] []
airflow.utils.yaml [] []
airflow.kubernetes.kubernetes_helper_functions [] []
airflow.lineage.entities [] []
airflow.kubernetes.pod_launcher_deprecated [] []
packaging [] []
airflow.jobs.scheduler_job_runner [] []
airflow.compat [] []
psutil [] []
pty [] []
airflow.models.xcom_arg [] []
importlib_metadata [] []
airflow.cli.commands.plugins_command [] []
importlib [] []
airflow.providers.sqlite.hooks [] []
airflow.utils.json [] []
airflow.example_dags.example_setup_teardown [] []
airflow.migrations.versions.0115_2_4_0_remove_smart_sensors [] []
airflow.serialization.serializers.numpy [] []
airflow.migrations.versions.0056_1_10_12_add_dag_hash_column_to_serialized_dag_ [] []
airflow.www.forms [] []
airflow.migrations.versions.0091_2_2_0_add_trigger_table_and_task_info [] []
airflow.cli.commands.config_command [] []
airflow.utils.log.log_reader [] []
airflow.example_dags.example_latest_only_with_trigger [] []
airflow.sensors.filesystem [] []
airflow.cli.commands.kubernetes_command [] []
airflow.api.client.api_client [] []
airflow.ti_deps.deps.runnable_exec_date_dep [] []
airflow.example_dags.example_branch_python_dop_operator_3 [] []
airflow.api_internal.internal_api_call [] []
airflow.providers.http [] []
airflow.migrations.versions.0032_1_10_0_fix_mysql_not_null_constraint [] []
pluggy [] []
airflow.migrations.versions.0002_1_5_0_create_is_encrypted [] []
airflow.providers.imap.sensors.imap_attachment [] []
airflow.ti_deps.deps.prev_dagrun_dep [] []
airflow.api_connexion.schemas.task_schema [] []
airflow.models.serialized_dag [] []
cgroupspy [] []
flask_appbuilder [] []
airflow.triggers [] []
airflow.utils.email [] []
airflow.decorators.setup_teardown [] []
airflow.example_dags.example_sensor_decorator [] []
airflow.ti_deps.deps.trigger_rule_dep [] []
airflow.providers.http.sensors [] []
airflow.api_connexion.schemas.variable_schema [] []
airflow.api.client [] []
airflow.operators.latest_only [] []
airflow.api_connexion.types [] []
airflow.example_dags.example_passing_params_via_test_command [] []
airflow.serialization.pydantic.job [] []
airflow.migrations.versions.0039_1_10_2_add_superuser_field [] []
airflow.migrations.versions.0033_1_10_0_fix_sqlite_foreign_key [] []
rich_argparse [] []
airflow.settings [] []
airflow.api_connexion.endpoints.update_mask [] []
airflow.cli.cli_parser [] []
airflow.api_connexion.endpoints.user_endpoint [] []
airflow.migrations.versions.0049_1_10_7_merge_heads [] []
airflow.typing_compat [] []
airflow.api_connexion.endpoints.plugin_endpoint [] []
airflow.migrations [] []
airflow.cli.commands.celery_command [] []
airflow.www.extensions.init_views [] []
airflow.operators.datetime [] []
airflow.utils.file [] []
airflow.notifications.basenotifier [] []
airflow.cli.commands.kerberos_command [] []
traceback [] []
airflow.migrations.versions.0087_2_1_4_add_index_on_state_dag_id_for_queued_ [] []
airflow.providers.sqlite.hooks.sqlite [] []
airflow.migrations.versions.0101_2_3_0_add_data_compressed_to_serialized_dag [] []
airflow.providers.imap [] []
airflow.serialization [] []
airflow.providers.imap.hooks [] []
airflow.models.base [] []
...dag_fuzz ['dag_fuzz'] []
flask_sqlalchemy [] []
flask_caching [] []
airflow.www.api.experimental [] []
airflow.migrations.versions.0059_2_0_0_drop_user_and_chart [] []
airflow.migrations.versions.0028_1_10_0_add_kubernetes_resource_checkpointing [] []
colorlog.logging [] []
airflow.migrations.versions.0118_2_4_2_add_missing_autoinc_fab [] []
airflow.api_connexion.endpoints.xcom_endpoint [] []
airflow.providers.common.sql.get_provider_info [] []
airflow.example_dags.example_short_circuit_decorator [] []
airflow.cli.commands.pool_command [] []
airflow.migrations.versions.0016_1_7_1_add_ti_state_index [] []
airflow.api_connexion.endpoints.dag_source_endpoint [] []
airflow.migrations.versions.0105_2_3_0_add_map_index_to_taskfail [] []
airflow.utils.orm_event_handlers [] []
airflow.cli.commands.provider_command [] []
airflow.www.extensions.init_cache [] []
airflow.api_connexion.schemas.dag_warning_schema [] []
colorlog.escape_codes [] []
airflow.sensors.time_delta [] []
pkgutil [] []
airflow.utils.db [] []
airflow.api.client.json_client [] []
airflow.migrations.versions.0107_2_3_0_add_map_index_to_log [] []
airflow.compat.functools [] []
airflow.migrations.versions.0009_1_6_0_dagrun_config [] []
pickle [] []
hashlib [] []
airflow.migrations.versions.0044_1_10_7_add_serialized_dag_table [] []
airflow.providers.sqlite.operators.sqlite [] []
airflow.example_dags.example_short_circuit_operator [] []
airflow.models.dag ['dag_fuzz'] []
airflow.migrations.versions.0050_1_10_7_increase_length_for_connection_password [] []
math [] []
kerberos [] []
decimal [] []
airflow.migrations.versions.0079_2_0_2_increase_size_of_connection_extra_field_ [] []
airflow.migrations.versions.0015_1_7_1_rename_user_table [] []
airflow.callbacks.base_callback_sink [] []
airflow.example_dags.example_local_kubernetes_executor [] []
airflow.www.fab_security.manager [] []
enum [] []
airflow.api [] []
logging [] []
flask_wtf [] []
airflow.migrations.versions.0120_2_5_0_add_updated_at_to_dagrun_and_ti [] []
airflow.utils.dates ['dag_fuzz'] []
airflow.utils.sqlalchemy [] []
airflow.serialization.serializers [] []
airflow.hooks.base [] []
airflow.logging_config [] []
airflow.decorators.task_group [] []
airflow.example_dags.example_skip_dag [] []
airflow.serialization.serializers.kubernetes [] []
airflow.kubernetes.pod [] []
airflow.models.connection [] []
airflow.www.views [] []
airflow.api_connexion.schemas.dag_run_schema [] []
authlib [] []
airflow.migrations.versions.0074_2_0_0_resource_based_permissions [] []
airflow.hooks.subprocess [] []
airflow.config_templates.default_celery [] []
airflow.example_dags.example_branch_day_of_week_operator [] []
airflow.www.extensions.init_robots [] []
airflow.models.taskinstancekey [] []
airflow.utils.net [] []
airflow.api_connexion.endpoints.version_endpoint [] []
airflow.utils.entry_points [] []
airflow.example_dags.example_branch_operator_decorator [] []
sqlparse [] []
airflow.api_connexion.schemas.xcom_schema [] []
airflow.example_dags.example_params_ui_tutorial [] []
airflow.www [] []
requests_toolbelt [] []
airflow.www.gunicorn_config [] []
airflow.utils.dot_renderer [] []
airflow.migrations.versions.0073_2_0_0_prefix_dag_permissions [] []
cattr [] []
deprecated [] []
airflow.kubernetes.kube_client [] []
requests_kerberos [] []
airflow.example_dags.example_sla_dag [] []
airflow.api_connexion.endpoints.connection_endpoint [] []
airflow.migrations.versions.0064_2_0_0_add_unique_constraint_to_conn_id [] []
airflow.utils.process_utils [] []
airflow.timetables.base [] []
airflow.utils.event_scheduler [] []
airflow.example_dags.example_xcomargs [] []
socket [] []
airflow.hooks.filesystem [] []
airflow.serialization.serializers.bignum [] []
airflow.contrib.utils.log [] []
airflow.utils.module_loading [] []
urllib [] []
airflow.migrations.versions.0099_2_3_0_add_task_log_filename_template_model [] []
airflow.secrets.environment_variables [] []
airflow.migrations.versions.0093_2_2_0_taskinstance_keyed_to_dagrun [] []
airflow.utils.deprecation_tools [] []
airflow.migrations.versions.0012_1_7_0_add_notification_sent_column_to_sla_miss [] []
airflow.exceptions [] []
airflow.migrations.versions.0030_1_10_0_add_kubernetes_scheduler_uniqueness [] []
airflow.executors.base_executor [] []
jinja2 [] []
airflow.utils.log.non_caching_file_handler [] []
datadog [] []
__future__ [] []
airflow.utils.task_group ['dag_fuzz'] []
typing [] []
kubernetes [] []
airflow.triggers.file [] []
airflow.www.fab_security.sqla.models [] []
glob [] []
airflow.utils [] []
airflow.providers.ftp [] []
airflow.migrations.versions.0031_1_10_0_merge_heads [] []
airflow.www.security [] []
airflow.migrations.versions.0106_2_3_0_update_migration_for_fab_tables_to_add_missing_constraints [] []
airflow.example_dags.libs [] []
airflow.utils.strings [] []
airflow.migrations.versions.0089_2_2_0_make_xcom_pkey_columns_non_nullable [] []
airflow.migrations.versions.0060_2_0_0_remove_id_column_from_xcom [] []
airflow.migrations.versions.0017_1_7_1_add_task_fails_journal_table [] []
airflow.utils.operator_helpers [] []
requests [] []
airflow.sensors [] []
airflow.contrib.operators [] []
airflow.listeners.spec.lifecycle [] []
airflow.models.taskreschedule [] []
airflow.migrations.versions.0126_2_7_0_add_index_to_task_instance_table [] []
airflow.cli.commands.sync_perm_command [] []
airflow.providers.http.operators.http [] []
airflow.triggers.external_task [] []
gzip [] []
airflow.sensors.date_time [] []
aiohttp [] []
csv [] []
setproctitle [] []
pendulum [] []
airflow.example_dags.example_complex [] []
airflow.dag_processing [] []
airflow.api_connexion.endpoints.dataset_endpoint [] []
airflow.utils.xcom [] []
airflow.hooks.dbapi [] []
airflow.models [] []
airflow.migrations.env [] []
airflow.example_dags.plugins.workday [] []
airflow.api_connexion.schemas.dag_source_schema [] []
airflow.migrations.versions.0085_2_1_3_add_queued_at_column_to_dagrun_table [] []
airflow.configuration [] []
airflow.api.common.experimental.get_lineage [] []
airflow.api_connexion.endpoints.extra_link_endpoint [] []
airflow.models.taskmixin [] []
cron_descriptor [] []
airflow.sensors.external_task [] []
airflow.example_dags.plugins.event_listener [] []
airflow.models.baseoperator [] []
airflow.models.errors [] []
airflow.serialization.pydantic.dataset [] []
yaml [] []
airflow.migrations.versions.0001_1_5_0_current_schema [] []
collections [] []
airflow.providers.common.sql.sensors [] []
airflow.api_internal [] []
airflow.utils.timezone ['dag_fuzz'] []
dataclasses [] []
airflow.contrib [] []
airflow.migrations.versions.0102_2_3_0_switch_xcom_table_to_use_run_id [] []
airflow.migrations.versions.0040_1_10_3_add_fields_to_dag [] []
airflow.hooks [] []
airflow.timetables.events [] []
time [] []
airflow.api.common.trigger_dag [] []
airflow.cli.commands.user_command [] []
rich [] []
airflow.api_connexion.schemas.error_schema [] []
airflow.migrations.versions.0109_2_3_1_add_index_for_event_in_log [] []
importlib_resources [] []
multiprocessing [] []
airflow.operators.generic_transfer [] []
pprint [] []
airflow.api_connexion.security [] []
ast [] []
airflow.example_dags.example_dag_decorator [] []
pydantic [] []
airflow.migrations.versions.0114_2_4_0_add_dataset_model [] []
getpass [] []
airflow.providers.common.sql.operators.sql [] []
airflow.models.dataset [] []
airflow.example_dags.example_branch_operator [] []
airflow.www.extensions.init_appbuilder [] []
airflow.cli.commands.info_command [] []
airflow.migrations.versions.0065_2_0_0_update_schema_for_smart_sensor [] []
airflow.www.app [] []
airflow.executors.debug_executor [] []
airflow.serialization.helpers [] []
sched [] []
airflow.ti_deps.dep_context [] []
airflow.utils.airflow_flask_app [] []
airflow.decorators.sensor [] []
airflow.models.dagcode [] []
celery [] []
airflow.api_connexion.endpoints.pool_endpoint [] []
secrets [] []
airflow.migrations.versions.0005_1_5_2_job_id_indices [] []
airflow.migrations.versions.0077_2_0_0_change_field_in_dagcode_to_mediumtext_ [] []
airflow.migrations.versions.0078_2_0_1_remove_can_read_permission_on_config_ [] []
airflow.serialization.serializers.builtin [] []
airflow.migrations.versions.0055_1_10_11_add_precision_to_execution_date_in_mysql [] []
threading [] []
airflow.example_dags.example_branch_labels [] []
airflow.executors.executor_constants [] []
airflow.serialization.serializers.pandas [] []
airflow.jobs [] []
airflow.www.api.experimental.endpoints [] []
airflow.api_connexion.schemas.dag_schema [] []
airflow.migrations.versions.0121_2_5_0_add_dagrunnote_and_taskinstancenote [] []
ftplib [] []
airflow.models.param ['dag_fuzz'] []
airflow.templates [] []
airflow.cli.commands.variable_command [] []
airflow.models.trigger [] []
itertools [] []
airflow.lineage.backend [] []
pandas [] []
airflow.utils.session [] []
airflow.example_dags.example_trigger_target_dag [] []
airflow.api_connexion.endpoints.request_dict [] []
sqlite3 [] []
airflow.migrations.versions.0070_2_0_0_fix_mssql_exec_date_rendered_task_instance [] []
airflow.migrations.versions.0072_2_0_0_add_k8s_yaml_to_rendered_templates [] []
airflow.providers.common.sql.hooks [] []
airflow.ti_deps.deps.valid_state_dep [] []
datetime [] []
airflow.stats [] []
airflow.www.extensions.init_session [] []
flask_limiter [] []
airflow.metrics.statsd_logger [] []
airflow.utils.edgemodifier [] []
airflow.migrations.versions.0110_2_3_2_add_cascade_to_dag_tag_foreignkey [] []
airflow.api_connexion.endpoints.event_log_endpoint [] []
airflow.example_dags [] []
airflow.serialization.pydantic [] []
pathspec [] []
airflow.executors.local_executor [] []
airflow.cli.commands.internal_api_command [] []
airflow.www.decorators [] []
airflow.migrations.versions.0104_2_3_0_migrate_rtif_to_use_run_id_and_map_index [] []
airflow.example_dags.example_task_group [] []
airflow.utils.hashlib_wrapper [] []
os [] []
airflow.jobs.triggerer_job_runner [] []
io [] []
airflow.template.templater [] []
airflow.migrations.versions.0019_1_7_1_add_fractional_seconds_to_mysql_tables [] []
flask_jwt_extended [] []
airflow.example_dags.tutorial_dag [] []
base64 [] []
configupdater [] []
airflow.serialization.pydantic.taskinstance [] []
ldap [] []
airflow.migrations.versions.0021_1_7_1_add_pid_field_to_taskinstance [] []
itsdangerous [] []
airflow.metrics.base_stats_logger [] []
airflow.www.fab_security.sqla.manager [] []
airflow.config_templates.airflow_local_settings [] []
airflow.kubernetes.volume [] []
daemon [] []
airflow.models.db_callback_request [] []
airflow.migrations.versions.0100_2_3_0_add_taskmap_and_map_id_on_taskinstance [] []
airflow.serialization.serialized_objects [] []
airflow.cli.commands [] []
smtplib [] []
airflow.utils.cli_app_builder [] []
airflow.secrets.local_filesystem [] []
lockfile [] []
airflow.www.session [] []
airflow.example_dags.libs.helper [] []
airflow.cli.commands.jobs_command [] []
airflow.api.common.experimental [] []
alembic [] []
copy [] []
flask_login [] []
airflow.utils.platform [] []
gevent [] []
airflow.www.extensions.init_appbuilder_links [] []
airflow.www.utils [] []
airflow.www.fab_security.sqla [] []
airflow.migrations.versions.0116_2_4_0_add_dag_owner_attributes_table [] []
httpx [] []
functools [] []
airflow.utils.cli_action_loggers [] []
airflow.providers.sqlite [] []
airflow.models.taskinstance [] []
airflow.api_connexion.endpoints.log_endpoint [] []
airflow.api.auth.backend.deny_all [] []
airflow.contrib.secrets [] []
airflow.models.dagpickle [] []
airflow.sensors.weekday [] []
airflow.utils.log.json_formatter [] []
sqlalchemy [] []
airflow.dag_processing.processor [] []
airflow.providers.ftp.get_provider_info [] []
airflow.providers.ftp.operators [] []
airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators [] []
airflow.ti_deps.deps.dag_ti_slots_available_dep [] []
airflow.providers.http.get_provider_info [] []
airflow.providers.common.sql.operators [] []
airflow.providers.imap.sensors [] []
marshmallow [] []
airflow.migrations.versions.0053_1_10_10_add_rendered_task_instance_fields_table [] []
airflow.sentry [] []
airflow.task [] []
zlib [] []
airflow.executors.celery_kubernetes_executor [] []
colorama [] []
airflow.operators.bash [] []
airflow.executors.celery_executor [] []
airflow.migrations.versions.0013_1_7_0_add_a_column_to_track_the_encryption_ [] []
airflow.providers.http.hooks [] []
termios [] []
airflow.api_connexion.endpoints.import_error_endpoint [] []
airflow.operators.smooth [] []
airflow.migrations.utils [] []
airflow.models.expandinput [] []
airflow.sensors.bash [] []
operator [] []
airflow.utils.mixins [] []
airflow.kubernetes.pod_generator [] []
airflow.utils.log.task_handler_with_custom_formatter [] []
airflow.example_dags.example_xcom [] []
re [] []
airflow.migrations.versions.0027_1_10_0_add_time_zone_awareness [] []
airflow.cli.cli_config [] []
airflow.migrations.versions.0052_1_10_10_add_pool_slots_field_to_task_instance [] []
airflow.example_dags.example_nested_branch_dag [] []
email [] []
airflow.cli [] []
airflow.metrics.datadog_logger [] []
airflow.ti_deps.deps.dagrun_exists_dep [] []
airflow.migrations.versions.0063_2_0_0_set_conn_type_as_non_nullable [] []
airflow.migrations.versions.0086_2_1_4_add_max_active_runs_column_to_dagmodel_ [] []
airflow.providers.ftp.hooks [] []
[] []
airflow.cli.commands.dag_processor_command [] []
airflow.api_connexion.schemas.connection_schema [] []
airflow.www.extensions.init_jinja_globals [] []
airflow.secrets.metastore [] []
airflow.www.extensions.init_wsgi_middlewares [] []
airflow.providers_manager [] []
airflow.www.extensions.init_manifest_files [] []
airflow.migrations.versions.0007_1_6_0_add_dagrun [] []
airflow.decorators.short_circuit [] []
airflow.migrations.versions.0084_2_1_0_resource_based_permissions_for_default_ [] []
airflow.migrations.versions.0014_1_7_0_add_is_encrypted_column_to_variable_ [] []
airflow.task.task_runner [] []
airflow.api_connexion.parameters [] []
airflow.contrib.hooks [] []
airflow.example_dags.example_datasets [] []
airflow.operators.branch [] []
airflow.example_dags.tutorial [] []
airflow.migrations.versions.0083_2_1_0_add_description_field_to_variable [] []
airflow.datasets.manager [] []
json [] []
distributed [] []
airflow.models.dagparam [] []
argcomplete [] []
airflow.serialization.serializers.timezone [] []
airflow.utils.state [] []
airflow.decorators.base [] []
nvd3 [] []
airflow.api.client.local_client [] []
airflow.callbacks.database_callback_sink [] []
airflow.migrations.versions.0051_1_10_8_add_dagtags_table [] []
airflow.migrations.versions.0025_1_8_2_add_ti_job_id_index [] []
airflow.migrations.versions.0113_2_4_0_compare_types_between_orm_and_db [] []
airflow.models.abstractoperator [] []
airflow.decorators [] []
airflow.timetables.simple [] []
airflow.executors.executor_loader [] []
airflow.ti_deps.deps.not_in_retry_period_dep [] []
airflow.api_connexion.endpoints.variable_endpoint [] []
airflow.macros [] []
airflow.migrations.versions.0038_1_10_2_add_sm_dag_index [] []
airflow.migrations.versions.0058_1_10_13_increase_length_of_fab_ab_view_menu_ [] []
airflow.executors [] []
airflow.migrations.versions.0022_1_7_1_add_dag_id_state_index_on_dag_run_table [] []
airflow.jobs.backfill_job_runner [] []
airflow.migrations.db_types [] []
airflow.utils.log [] []
airflow.api.auth.backend.kerberos_auth [] []
airflow.providers.ftp.sensors.ftp [] []
airflow.migrations.versions.0023_1_8_2_add_max_tries_column_to_task_instance [] []
airflow.api_connexion.endpoints.task_endpoint [] []
airflow.api_connexion.schemas.provider_schema [] []
airflow.utils.db_cleanup [] []
airflow.api_connexion.endpoints.task_instance_endpoint [] []
airflow.api_internal.endpoints [] []
graphviz [] []
airflow.providers.sqlite.operators [] []
airflow.config_templates.default_webserver_config [] []
airflow.kubernetes.secret [] []
airflow.notifications [] []
airflow.models.log [] []
airflow.migrations.versions.0024_1_8_2_make_xcom_value_column_a_large_binary [] []
airflow.policies [] []
airflow.cli.commands.db_command [] []
airflow.utils.log.colored_log [] []
airflow.api_connexion.schemas.trigger_schema [] []
airflow.sensors.time_sensor [] []
argparse [] []
airflow.jobs.base_job_runner [] []
airflow.migrations.versions.0097_2_3_0_increase_length_of_email_and_username [] []
airflow.migrations.versions.0045_1_10_7_add_root_dag_id_to_dag [] []
airflow.api_connexion.endpoints.provider_endpoint [] []
airflow.plugins_manager [] []
pathlib [] []
airflow.api_connexion.endpoints.config_endpoint [] []
airflow.cli.commands.standalone_command [] []
airflow.metrics.validators [] []
airflow.migrations.versions.0029_1_10_0_add_executor_config_to_task_instance [] []
airflow.migrations.versions.0095_2_2_4_add_session_table_to_db [] []
airflow.www.api [] []
airflow.triggers.testing [] []
airflow.www.extensions.init_dagbag [] []
airflow.models.dagrun [] []
airflow.example_dags.example_task_group_decorator [] []
subprocess [] []
airflow.ti_deps [] []
airflow.api.auth.backend.default [] []
airflow.security [] []
airflow.operators.trigger_dagrun [] []
airflow.utils.jwt_signer [] []
airflow.metrics.otel_logger [] []
airflow.migrations.versions.0082_2_1_0_increase_pool_name_size_in_taskinstance [] []
airflow.api.common.experimental.get_dag_run_state [] []
airflow.api_connexion.schemas.event_log_schema [] []
airflow.jobs.local_task_job_runner [] []
airflow.contrib.utils [] []
airflow.utils.log.secrets_masker [] []
airflow.migrations.versions.0111_2_3_3_add_indexes_for_cascade_deletes [] []
airflow.api.common.experimental.get_task [] []
queue [] []
airflow.api_connexion.schemas [] []
airflow.listeners.listener [] []
airflow.migrations.versions.0125_2_6_2_add_onupdate_cascade_to_taskmap [] []
airflow.operators.subdag [] []
airflow.ti_deps.deps.mapped_task_expanded [] []
airflow [] []
airflow.utils.configuration [] []
airflow.api.auth [] []
airflow.migrations.versions.0010_1_6_2_add_password_column_to_user [] []
airflow.migrations.versions.0004_1_5_0_more_logging_into_task_isntance [] []
airflow.sensors.base [] []
airflow.models.slamiss [] []
warnings [] []
airflow.api.common.mark_tasks [] []
random [] []
markupsafe [] []
pygments [] []
airflow.utils.timeout [] []
airflow.timetables.trigger [] []
airflow.api_connexion.schemas.common_schema [] []
airflow.migrations.versions.0054_1_10_10_add_dag_code_table [] []
airflow.metrics [] []
airflow.migrations.versions.0088_2_2_0_improve_mssql_compatibility [] []
airflow.ti_deps.deps.not_previously_skipped_dep [] []
zipfile [] []
bisect [] []
airflow.migrations.versions.0041_1_10_3_add_schedule_interval_to_dag [] []
airflow.example_dags.example_trigger_controller_dag [] []
airflow.api.common.experimental.get_dag_runs [] []
airflow.ti_deps.deps.dagrun_backfill_dep [] []
sys [] []
airflow.migrations.versions.0018_1_7_1_add_dag_stats_table [] []
airflow.decorators.python_virtualenv [] []
airflow.ti_deps.deps.dag_unpaused_dep [] []
airflow.utils.log.trigger_handler [] []
airflow.api.common [] []
airflow.cli.commands.connection_command [] []
airflow.utils.types [] []
airflow.api_connexion.endpoints.dag_run_endpoint [] []
airflow.task.task_runner.base_task_runner [] []
pyarrow [] []
airflow.timetables.interval [] []
airflow.models.dagbag [] []
airflow.models.variable [] []
airflow.models.operator [] []
airflow.serialization.enums [] []
airflow.migrations.versions.0061_2_0_0_increase_length_of_pool_name [] []
dateutil [] []
airflow.api.common.experimental.delete_dag [] []
airflow.api.auth.backend.session [] []
airflow.callbacks [] []
slugify [] []

Directories in report

Directory