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
Runtime coverage analysis
Complex functions with low coverage
Files and Directories in report
Files in report
Directories in report
Metadata section
Function call coverage
Function in each files in report
Report generation date: 2022-12-25

Project overview: airflow

High level conclusions

Reachability and coverage overview

Functions statically reachable by fuzzers
1.86%
176/9444
Cyclomatic complexity statically reachable by fuzzers
1.87%
559/29934
Functions covered at runtime
3996

Fuzzers overview

Fuzzer Fuzzer filename Functions Reached Functions unreached Fuzzer depth Files reached Basic blocks reached Cyclomatic complexity Details
dag_fuzz dag_fuzz.py 177 9268 6 12 79 559 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 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 103 40.5%
gold [1:9] 0 0.0%
yellow [10:29] 0 0.0%
greenyellow [30:49] 0 0.0%
lawngreen 50+ 151 59.4%
All colors 254 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 196 airflow.models.dag.DAG.__init__ call site airflow.models.dag.DAG.get_template_env
10 149 airflow.utils.log.file_task_handler.FileTaskHandler.__init__ call site warnings.warn
10 212 airflow.utils.task_group.TaskGroup.__init__ call site airflow.utils.helpers.validate_group_key
8 10 airflow.utils.dates.days_ago call site airflow.models.dag.DAG.__init__
8 225 airflow.utils.task_group.TaskGroup.__init__ call site airflow.utils.task_group.TaskGroup.add
7 104 airflow.models.param.ParamsDict.__init__ call site airflow.models.param.Param.__init__
6 160 airflow.models.dag.create_timetable call site airflow.utils.log.file_task_handler.FileTaskHandler.__init__
5 0 EP call site airflow.utils.dates.days_ago
5 248 airflow.models.dag.DAG.__init__ call site fdp.ConsumeString
4 137 airflow.models.dag.DAG.__init__ call site .isinstance
3 145 airflow.models.dag.DAG.__init__ call site airflow.utils.log.file_task_handler.FileTaskHandler.__init__
3 192 airflow.models.dag.DAG.__init__ call site access_control.items

Runtime coverage analysis

Covered functions
624
Functions that are reachable but not covered
155
Reachable functions
177
Percentage of reachable functions covered
12.43%
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 55
airflow.models.param 85
airflow.utils.helpers 8
airflow.utils.log.file_task_handler 3
airflow.timetables._cron 8
airflow.dag_processing.processor 1
airflow.utils.task_group 18
airflow.exceptions 1

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 2 4 4019 0 12860 12322
airflow.models.taskinstance.SimpleTaskInstance.from_dict airflow.models.taskinstance 2 ['N/A', 'N/A'] 1 0 1 2 4 82 0 250 235
airflow.www.decorators.action_logging.log_action.wrapper airflow.www.decorators 2 ['N/A', 'N/A'] 12 0 2 4 5 3530 0 11282 187
airflow.configuration.AirflowConfigParser.as_dict airflow.configuration 7 ['N/A', 'N/A', 'N/A', 'N/A', 'N/A', 'N/A', 'N/A'] 11 0 8 9 7 93 2 321 113
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.sensors.base.BaseSensorOperator.execute airflow.sensors.base 2 ['N/A', 'N/A'] 12 0 2 8 6 343 0 1095 98
airflow.providers_manager.ProvidersManager._discover_hooks_from_hook_class_names airflow.providers_manager 6 ['N/A', 'N/A', 'N/A', 'N/A', 'N/A', 'N/A'] 3 0 5 7 6 61 6 200 89

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

Functions statically reachable by fuzzers
45.34%
4282/9444
Cyclomatic complexity statically reachable by fuzzers
45.8%
13711 / 29934

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
...dag_fuzz.main 1460 113 7.739% []
airflow.utils.dates.date_range 46 0 0.0% []
datetime.date.fromisoformat 494 169 34.21% []
airflow.models.dag.DAG._get_task_instances 88 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% []
threading.Event 662 24 3.625% []
sys.version.replace 101 12 11.88% []
signal.Signals 48 8 16.66% []
contextlib.closing 327 45 13.76% []
session.send 1203 232 19.28% []
typing_extensions.get_type_hints 861 325 37.74% []
typing.NamedTuple.end.timestamp 932 318 34.12% []
airflow.models.taskinstance.clear_task_instances 45 0 0.0% []
airflow.models.taskinstance.TaskInstance.refresh_from_db 33 0 0.0% []
airflow.models.taskinstance.TaskInstance.check_and_change_state_before_execution 48 0 0.0% []
airflow.models.taskinstance.TaskInstance._run_raw_task 70 0 0.0% []
airflow.models.taskinstance.TaskInstance._execute_task 33 0 0.0% []
airflow.models.taskinstance.TaskInstance.handle_failure 49 0 0.0% []
airflow.models.taskinstance.TaskInstance.filter_for_tis 36 0 0.0% []
airflow.models.dagrun.DagRun.update_state._UnfinishedStates.recalculate 58 0 0.0% []
airflow.models.dagrun.DagRun._check_for_removed_or_restored_tasks 48 4 8.333% []
airflow.models.baseoperator.partial 64 2 3.125% []
airflow.models.xcom.BaseXCom.get_many 36 1 2.777% []
airflow.ti_deps.deps.prev_dagrun_dep.PrevDagrunDep._get_dep_statuses 35 0 0.0% []
airflow.models.skipmixin.SkipMixin.skip_all_except 31 0 0.0% []
airflow.models.abstractoperator.AbstractOperator.expand_mapped_task 47 0 0.0% []
airflow.models.abstractoperator.AbstractOperator.render_template 31 0 0.0% []
pendulum.tz.timezone.Timezone 211 70 33.17% ['dag_fuzz']
airflow.configuration.AirflowConfigParser.get 36 18 50.0% []
airflow.configuration.initialize_config 37 20 54.05% []
pendulum.tz.local_timezone 152 28 18.42% []
os.system 439 31 7.061% []
rich.console.Console.export_text 973 469 48.20% []
result.strip 685 210 30.65% []
default.copy 853 279 32.70% []
airflow.config_templates.airflow_local_settings 72 29 40.27% []
k.lower 74 24 32.43% []
re.search 148 76 51.35% []
match.group 161 31 19.25% []
shlex.quote 262 27 10.30% []
subprocess.call 956 160 16.73% []
configparser._UNSET 696 154 22.12% []
old.search 256 100 39.06% []
urllib.parse.urlsplit.netloc.partition 595 38 6.386% []
json.dump 31 11 35.48% []
collections.defaultdict.get 667 245 36.73% []
config.get 109 24 22.01% []
state.lower 405 129 31.85% []
d.values 430 112 26.04% []
cryptography.fernet.MultiFernet 136 35 25.73% []
pathlib.Path.suffix.lower 925 105 11.35% []
shutil.copyfileobj 787 45 5.717% []
base64.urlsafe_b64decode 308 4 1.298% []
pendulum.time 105 32 30.47% []
logger.exception 127 48 37.79% []
packaging.version.Version 210 76 36.19% []
flask.json.provider.JSONProvider.__init__ 104 31 29.80% []
info.data.get 37 20 54.05% []
message.format 572 126 22.02% []
airflow.utils.log.file_task_handler.FileTaskHandler._read 55 0 0.0% []
response.raise_for_status 48 22 45.83% []
copy.deepcopy 176 73 41.47% ['dag_fuzz']
source._deprecation_replacements.copy 613 39 6.362% []
query.options 726 299 41.18% []
timezone.utc_epoch 79 20 25.31% []
airflow.utils.task_group.TaskGroup.__init__ 39 21 53.84% ['dag_fuzz']
path.split 319 103 32.28% []
context.get_current_heads 1213 238 19.62% []
t.are_dependencies_met 1647 252 15.30% []
sqlalchemy.ext.associationproxy.association_proxy.in_ 766 244 31.85% []
sqlalchemy.ext.mutable.MutableDict.as_mutable 270 101 37.40% []
attributes.append 846 273 32.26% []
airflow.utils.operator_helpers.context_to_airflow_vars 34 2 5.882% []
f.flush 84 23 27.38% []
airflow.utils.email.send_mime_email 40 0 0.0% []
filters.append 528 151 28.59% []
smtplib.SMTP 513 110 21.44% []
address.strip 902 384 42.57% []
airflow.serialization.serde.serialize 41 0 0.0% []
airflow.serialization.serde.deserialize 35 0 0.0% []
o.as_tuple 74 15 20.27% []
p.to_json 161 12 7.453% []
delta.total_seconds 242 36 14.87% []
name.strip 232 90 38.79% []
pattern.rstrip 44 18 40.90% []
pathspec.patterns.GitWildMatchPattern 70 25 35.71% []
tempfile.NamedTemporaryFile 417 42 10.07% []
table.indexes.add 1578 734 46.51% []
tags.append 245 47 19.18% []
metadata.get 242 120 49.58% []
op.mro 33 10 30.30% []
jinja2.nativetypes.NativeEnvironment 68 30 44.11% []
x.__getattribute__ 601 271 45.09% []
backend.strip 1353 235 17.36% []
jinja2.sandbox.is_internal_attribute 153 52 33.98% []
airflow.ti_deps.deps.trigger_rule_dep.TriggerRuleDep._evaluate_trigger_rule._iter_upstream_conditions 102 0 0.0% []
getpass.getpass 110 17 15.45% []
werkzeug.security.check_password_hash 51 15 29.41% []
app.config.get 696 207 29.74% []
r.dag_id.replace 40 21 52.5% []
jinja2.utils.htmlsafe_json_dumps 315 115 36.50% []
croniter.croniter.get_prev 557 163 29.26% []
date.isoformat 272 95 34.92% []
tasks.append 471 85 18.04% []
row.values 209 89 42.58% []
flask.helpers.flash 145 45 31.03% []
airflow.utils.process_utils.reap_process_group.signal_procs 49 0 0.0% []
z.infolist 812 168 20.68% []
runtime.total_seconds 494 179 36.23% []
random.choice 358 16 4.469% []
lockfile.pidlockfile.remove_existing_pidfile 69 18 26.08% []
c.label 71 12 16.90% []
cron_descriptor.ExpressionDescriptor.get_description 265 115 43.39% ['dag_fuzz']
url.get_backend_name 239 95 39.74% []
parser.add_argument 170 48 28.23% []
cursor.fetchone 699 203 29.04% []
flask.sessions.SecureCookieSessionInterface.__init__ 139 61 43.88% []
rich.table.Table.add_row 393 83 21.11% []
http.server.HTTPServer.serve_forever 56 15 26.78% []
ast.literal_eval 110 23 20.90% []
sock.close 139 52 37.41% []
options.items 652 163 25.0% []
sqlalchemy.ext.compiler.compiles 50 24 48.0% []
compiler.process 2189 431 19.68% []
actions.append 271 71 26.19% []
kerberos.authGSSServerClean 116 33 28.44% []
i.strip 400 73 18.25% []
itsdangerous.url_safe.URLSafeSerializer.dumps 41 17 41.46% []
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
[] []
airflow.providers.http.operators [] []
airflow.api_connexion.endpoints.variable_endpoint [] []
airflow.models.connection [] []
airflow.callbacks.base_callback_sink [] []
airflow.www.extensions.init_wsgi_middlewares [] []
airflow.settings [] []
airflow.migrations.versions.0009_1_6_0_dagrun_config [] []
airflow.utils.timeout [] []
copy [] []
airflow.api_connexion.endpoints [] []
airflow.secrets.base_secrets [] []
airflow.callbacks.callback_requests [] []
airflow.api.common.experimental.get_dag_run_state [] []
airflow.utils.db [] []
airflow.dag_processing.manager [] []
airflow.example_dags.example_branch_labels [] []
airflow.timetables.trigger [] []
airflow.utils.types [] []
airflow.cli.commands.webserver_command [] []
airflow.migrations.versions.0026_1_8_2_increase_text_size_for_mysql [] []
airflow.utils.sqlalchemy [] []
airflow.task.task_runner.cgroup_task_runner [] []
airflow.providers.imap.hooks [] []
airflow.api_connexion.schemas.variable_schema [] []
ast [] []
airflow.ti_deps.deps.pool_slots_available_dep [] []
airflow.contrib.operators [] []
airflow.api.auth.backend.session [] []
airflow.example_dags.example_time_delta_sensor_async [] []
airflow.example_dags.example_external_task_marker_dag [] []
jmespath [] []
airflow.callbacks.database_callback_sink [] []
airflow.migrations.versions.0019_1_7_1_add_fractional_seconds_to_mysql_tables [] []
airflow.timetables.simple [] []
sqlparse [] []
logging [] []
airflow.api_connexion.schemas.common_schema [] []
airflow.ti_deps.deps.not_in_retry_period_dep [] []
airflow.utils.dag_edges [] []
airflow.templates [] []
airflow.providers.imap.get_provider_info [] []
airflow.kubernetes.pod [] []
airflow.datasets.manager [] []
airflow.providers.ftp.get_provider_info [] []
airflow.api.common.experimental.pool [] []
airflow.models.baseoperator [] []
airflow.api_connexion.schemas.role_and_permission_schema [] []
airflow.api_connexion.schemas.version_schema [] []
airflow.sentry [] []
airflow.www.forms [] []
airflow.models.serialized_dag [] []
airflow.listeners.listener [] []
airflow.migrations.versions.0080_2_0_2_change_default_pool_slots_to_1 [] []
airflow.models.dag ['dag_fuzz'] []
airflow.models.log [] []
airflow.migrations.versions.0003_1_5_0_for_compatibility [] []
airflow.cli.commands.kerberos_command [] []
airflow.kubernetes.pod_launcher_deprecated [] []
graphviz [] []
airflow.api_connexion.endpoints.plugin_endpoint [] []
airflow.serialization.enums [] []
airflow.example_dags.tutorial_dag [] []
airflow.api_connexion.endpoints.user_endpoint [] []
jsonschema [] []
signal [] []
airflow.migrations.versions.0048_1_10_3_remove_dag_stat_table [] []
airflow.contrib.task_runner [] []
airflow.hooks [] []
airflow.migrations.versions.0102_2_3_0_switch_xcom_table_to_use_run_id [] []
airflow.www.extensions.init_session [] []
airflow.api_connexion.schemas.plugin_schema [] []
airflow.providers.imap.hooks.imap [] []
airflow.migrations.versions.0008_1_6_0_task_duration [] []
wtforms [] []
jwt [] []
dateutil [] []
airflow.models.taskmap [] []
airflow.decorators.external_python [] []
atexit [] []
airflow.migrations.versions.0006_1_6_0_adding_extra_to_log [] []
airflow.api_internal [] []
airflow.utils.timezone ['dag_fuzz'] []
ftplib [] []
airflow.utils.orm_event_handlers [] []
email [] []
airflow.api.common.experimental.get_lineage [] []
importlib [] []
airflow.jobs [] []
cron_descriptor [] []
airflow.migrations.versions.0065_2_0_0_update_schema_for_smart_sensor [] []
airflow.migrations.versions.0055_1_10_11_add_precision_to_execution_date_in_mysql [] []
airflow.example_dags.example_python_operator [] []
sqlite3 [] []
operator [] []
nvd3 [] []
airflow.cli.commands.config_command [] []
airflow.api_connexion.schemas.enum_schemas [] []
termcolor [] []
smtplib [] []
airflow.security.permissions [] []
daemon [] []
airflow.api_connexion.endpoints.dag_endpoint [] []
requests [] []
airflow.migrations.versions.0108_2_3_0_default_dag_view_grid [] []
airflow.providers.common.sql.sensors.sql [] []
airflow.api_connexion.schemas.config_schema [] []
airflow.migrations.versions.0015_1_7_1_rename_user_table [] []
datadog [] []
airflow.migrations.versions.0092_2_2_0_add_data_interval_start_end_to_dagmodel_and_dagrun [] []
airflow.api_connexion.endpoints.version_endpoint [] []
airflow.ti_deps.deps.mapped_task_expanded [] []
airflow.api_connexion.security [] []
airflow.utils.code_utils [] []
airflow.serialization.serializers.bignum [] []
colorlog.escape_codes [] []
airflow.api_connexion.schemas.health_schema [] []
authlib [] []
airflow.utils.json [] []
airflow.www.app [] []
sqlalchemy_jsonfield [] []
airflow.typing_compat [] []
itertools [] []
airflow.migrations.versions.0083_2_1_0_add_description_field_to_variable [] []
__future__ [] []
airflow.migrations.versions.0074_2_0_0_resource_based_permissions [] []
airflow.migrations.versions.0034_1_10_0_index_taskfail [] []
kubernetes [] []
flask_caching [] []
airflow.migrations.env [] []
airflow.example_dags.example_xcomargs [] []
asyncio [] []
airflow.ti_deps.deps.ready_to_reschedule [] []
airflow.providers.sqlite [] []
airflow.example_dags.example_skip_dag [] []
airflow.serialization.serializers.numpy [] []
airflow.contrib.utils [] []
airflow.utils.cli_app_builder [] []
airflow.migrations.versions.0104_2_3_0_migrate_rtif_to_use_run_id_and_map_index [] []
kerberos [] []
airflow.migrations.versions.0035_1_10_2_add_idx_log_dag [] []
airflow.api.auth.backend.basic_auth [] []
airflow.utils.deprecation_tools [] []
airflow.ti_deps.deps.dag_ti_slots_available_dep [] []
airflow.secrets.environment_variables [] []
airflow.decorators.sensor [] []
airflow.models.dagrun [] []
airflow.migrations.versions.0115_2_4_0_remove_smart_sensors [] []
airflow.example_dags.example_datasets [] []
distributed [] []
airflow.migrations.versions.0022_1_7_1_add_dag_id_state_index_on_dag_run_table [] []
airflow.migrations.versions.0084_2_1_0_resource_based_permissions_for_default_ [] []
airflow.contrib.utils.log [] []
airflow.utils.state [] []
airflow.providers.sqlite.get_provider_info [] []
pluggy [] []
airflow.migrations.versions.0039_1_10_2_add_superuser_field [] []
airflow.migrations.versions.0098_2_3_0_added_timetable_description_column [] []
airflow.jobs.scheduler_job [] []
airflow.compat.functools [] []
typing [] []
airflow.utils.weekday [] []
airflow.serialization.serde [] []
airflow.utils.email [] []
airflow.migrations.versions.0002_1_5_0_create_is_encrypted [] []
airflow.migrations.versions.0017_1_7_1_add_task_fails_journal_table [] []
airflow.models.param ['dag_fuzz'] []
airflow.api_connexion.schemas.log_schema [] []
airflow.migrations.versions.0032_1_10_0_fix_mysql_not_null_constraint [] []
airflow.secrets.local_filesystem [] []
airflow.utils.edgemodifier [] []
airflow.cli.commands.user_command [] []
airflow.cli.commands.provider_command [] []
airflow.providers.ftp.sensors [] []
airflow.migrations.versions.0105_2_3_0_add_map_index_to_taskfail [] []
airflow.migrations.versions.0075_2_0_0_add_description_field_to_connection [] []
airflow.utils.yaml [] []
airflow.migrations.versions.0062_2_0_0_add_dagrun_run_type [] []
airflow.hooks.dbapi [] []
airflow.providers.sqlite.hooks.sqlite [] []
airflow.serialization.serialized_objects [] []
airflow.example_dags.example_short_circuit_decorator [] []
atheris [] []
getpass [] []
airflow.api_internal.endpoints.rpc_api_endpoint [] []
airflow.api.common.experimental [] []
airflow.executors.base_executor [] []
airflow.migrations.versions.0007_1_6_0_add_dagrun [] []
airflow.ti_deps.deps.dagrun_exists_dep [] []
airflow.utils.log.action_logger [] []
airflow.listeners.spec [] []
airflow.utils.scheduler_health [] []
airflow.operators.bash [] []
airflow.operators.weekday [] []
airflow.utils.task_group ['dag_fuzz'] []
rich [] []
airflow.serialization.helpers [] []
airflow.models.skipmixin [] []
airflow.cli.commands.rotate_fernet_key_command [] []
airflow.www.extensions.init_appbuilder [] []
airflow.decorators.branch_python [] []
airflow.utils.entry_points [] []
airflow.lineage.backend [] []
airflow.migrations.versions.0033_1_10_0_fix_sqlite_foreign_key [] []
airflow.ti_deps.deps.dagrun_backfill_dep [] []
airflow.api.common [] []
collections [] []
airflow.utils.log.log_reader [] []
airflow.ti_deps.deps.prev_dagrun_dep [] []
airflow.www [] []
airflow.migrations.versions.0030_1_10_0_add_kubernetes_scheduler_uniqueness [] []
airflow.migrations.versions.0023_1_8_2_add_max_tries_column_to_task_instance [] []
airflow.executors.executor_loader [] []
airflow.utils.dot_renderer [] []
airflow.providers.ftp.hooks.ftp [] []
airflow.migrations.versions.0112_2_4_0_add_dagwarning_model [] []
airflow.decorators.base [] []
airflow.models.tasklog [] []
colorlog.logging [] []
airflow.kubernetes.kube_client [] []
airflow.api_connexion.endpoints.import_error_endpoint [] []
colorama [] []
sched [] []
pickle [] []
celery [] []
airflow.api_connexion.schemas.xcom_schema [] []
airflow.migrations.versions.0037_1_10_2_add_task_reschedule_table [] []
airflow.operators.datetime [] []
airflow.utils.weight_rule [] []
airflow.compat [] []
airflow.utils.db_cleanup [] []
airflow.example_dags.example_sensors [] []
airflow.migrations.versions.0072_2_0_0_add_k8s_yaml_to_rendered_templates [] []
locale [] []
airflow.listeners.spec.taskinstance [] []
airflow.api_connexion.endpoints.provider_endpoint [] []
airflow.models.taskfail [] []
flask_openid [] []
cgroupspy [] []
airflow.executors.celery_executor [] []
airflow.utils.helpers ['dag_fuzz'] []
airflow.models.taskmixin [] []
airflow.operators.latest_only [] []
airflow.example_dags.example_latest_only [] []
airflow.providers.common.sql.get_provider_info [] []
airflow.ti_deps.deps.trigger_rule_dep [] []
airflow.migrations.versions.0025_1_8_2_add_ti_job_id_index [] []
math [] []
airflow.www.fab_security [] []
airflow.operators.generic_transfer [] []
airflow.migrations.versions.0042_1_10_3_task_reschedule_fk_on_cascade_delete [] []
airflow.migrations.versions.0031_1_10_0_merge_heads [] []
airflow.serialization.serializers [] []
airflow.operators [] []
airflow.migrations.versions.0103_2_3_0_add_callback_request_table [] []
airflow.config_templates.default_celery [] []
markupsafe [] []
airflow.api_connexion.endpoints.connection_endpoint [] []
airflow.contrib.sensors [] []
airflow.models.dagcode [] []
airflow.kubernetes.volume_mount [] []
airflow.ti_deps [] []
airflow.version [] []
airflow.plugins_manager [] []
airflow.api.common.experimental.get_task_instance [] []
airflow.utils.operator_resources [] []
airflow.migrations.versions [] []
dataclasses [] []
pkgutil [] []
airflow.example_dags.example_branch_python_dop_operator_3 [] []
airflow.contrib.secrets [] []
weakref [] []
airflow.models.mappedoperator [] []
airflow.config_templates.airflow_local_settings [] []
airflow.migrations.versions.0011_1_6_2_dagrun_start_end [] []
airflow.executors.local_kubernetes_executor [] []
airflow.example_dags.example_sla_dag [] []
airflow.hooks.base [] []
airflow.models.db_callback_request [] []
airflow.example_dags.example_subdag_operator [] []
airflow.timetables [] []
airflow.api_connexion [] []
airflow.lineage.entities [] []
airflow.ti_deps.dependencies_deps [] []
airflow.example_dags.example_nested_branch_dag [] []
airflow.api_connexion.schemas.dataset_schema [] []
markdown_it [] []
airflow.www.extensions.init_robots [] []
airflow.migrations.versions.0001_1_5_0_current_schema [] []
airflow.api_connexion.schemas.dag_warning_schema [] []
airflow.example_dags.example_bash_operator [] []
airflow.executors.celery_kubernetes_executor [] []
airflow.triggers.testing [] []
hashlib [] []
airflow.api_connexion.endpoints.xcom_endpoint [] []
tty [] []
airflow.migrations.versions.0091_2_2_0_add_trigger_table_and_task_info [] []
airflow.example_dags.example_dag_decorator [] []
airflow.cli.commands.info_command [] []
airflow.models.base [] []
airflow.migrations.versions.0101_2_3_0_add_data_compressed_to_serialized_dag [] []
bz2 [] []
os [] []
configparser [] []
enum [] []
airflow.migrations.versions.0005_1_5_2_job_id_indices [] []
airflow.migrations.versions.0114_2_4_0_add_dataset_model [] []
lockfile [] []
airflow.models.taskinstance [] []
airflow.models.dagparam [] []
airflow.providers.common.sql.sensors [] []
airflow.serialization.serializers.datetime [] []
pandas [] []
airflow.task.task_runner.base_task_runner [] []
airflow.api_connexion.endpoints.request_dict [] []
airflow.models.dagbag [] []
airflow.migrations.versions.0096_2_2_4_adding_index_for_dag_id_in_job [] []
airflow.executors.kubernetes_executor [] []
airflow.example_dags.libs [] []
airflow.datasets [] []
airflow.sensors.date_time [] []
airflow.migrations.versions.0071_2_0_0_add_job_id_to_dagrun_table [] []
socket [] []
urllib [] []
marshmallow [] []
airflow.www.blueprints [] []
airflow.migrations.versions.0014_1_7_0_add_is_encrypted_column_to_variable_ [] []
airflow.migrations.versions.0067_2_0_0_add_external_executor_id_to_ti [] []
airflow.migrations [] []
airflow.decorators.python [] []
warnings [] []
airflow.migrations.versions.0111_2_3_3_add_indexes_for_cascade_deletes [] []
airflow.example_dags.example_kubernetes_executor [] []
airflow.api_connexion.schemas.dag_schema [] []
airflow.migrations.versions.0018_1_7_1_add_dag_stats_table [] []
airflow.ti_deps.deps.not_previously_skipped_dep [] []
airflow.migrations.versions.0073_2_0_0_prefix_dag_permissions [] []
pygments [] []
struct [] []
airflow.utils.context [] []
sys [] []
typing_extensions [] []
airflow.macros.hive [] []
airflow.sensors.python [] []
airflow.utils.cli_action_loggers [] []
airflow.api_connexion.endpoints.config_endpoint [] []
airflow.models.dagwarning [] []
io [] []
airflow.timetables.interval [] []
shutil [] []
airflow.api.auth.backend.kerberos_auth [] []
airflow.timetables.events [] []
tenacity [] []
airflow.example_dags.tutorial_taskflow_api_virtualenv [] []
airflow.migrations.versions.0028_1_10_0_add_kubernetes_resource_checkpointing [] []
airflow.providers.http [] []
airflow.api_connexion.schemas.task_instance_schema [] []
airflow.migrations.versions.0088_2_2_0_improve_mssql_compatibility [] []
airflow.utils.process_utils [] []
airflow.migrations.versions.0082_2_1_0_increase_pool_name_size_in_taskinstance [] []
airflow.migrations.versions.0049_1_10_7_merge_heads [] []
airflow.migrations.versions.0061_2_0_0_increase_length_of_pool_name [] []
airflow.providers.ftp.hooks [] []
airflow.kubernetes [] []
airflow.api_connexion.endpoints.dag_warning_endpoint [] []
airflow.api_connexion.schemas.dag_source_schema [] []
subprocess [] []
airflow.migrations.versions.0051_1_10_8_add_dagtags_table [] []
airflow.providers.imap [] []
airflow.migrations.versions.0027_1_10_0_add_time_zone_awareness [] []
airflow.models.crypto [] []
airflow.cli.commands.db_command [] []
airflow.www.auth [] []
airflow.api.auth.backend [] []
airflow.cli.simple_table [] []
psutil [] []
airflow.utils.decorators [] []
airflow.serialization.json_schema [] []
airflow.triggers.temporal [] []
airflow.api.common.trigger_dag [] []
airflow.migrations.versions.0013_1_7_0_add_a_column_to_track_the_encryption_ [] []
airflow.utils.serve_logs [] []
airflow.utils.jwt_signer [] []
airflow.executors.sequential_executor [] []
airflow.utils.log.secrets_masker [] []
airflow.timetables._cron ['dag_fuzz'] []
airflow.www.fab_security.views [] []
airflow.utils.strings [] []
...dag_fuzz ['dag_fuzz'] []
airflow.api_connexion.types [] []
airflow.kubernetes.pod_generator [] []
functools [] []
airflow.listeners.spec.lifecycle [] []
importlib_metadata [] []
airflow.example_dags.example_xcom [] []
airflow.example_dags.libs.helper [] []
airflow.api.auth.backend.deny_all [] []
airflow.providers.http.hooks [] []
airflow.migrations.versions.0107_2_3_0_add_map_index_to_log [] []
airflow.example_dags.example_trigger_target_dag [] []
airflow.example_dags.plugins.workday [] []
airflow.migrations.versions.0081_2_0_2_rename_last_scheduler_run_column [] []
gevent [] []
airflow.migrations.versions.0079_2_0_2_increase_size_of_connection_extra_field_ [] []
airflow.cli.commands [] []
airflow.migrations.versions.0010_1_6_2_add_password_column_to_user [] []
airflow.migrations.versions.0024_1_8_2_make_xcom_value_column_a_large_binary [] []
airflow.configuration [] []
airflow.logging_config [] []
airflow.task.task_runner [] []
airflow.www.fab_security.sqla.models [] []
airflow.providers.common.sql [] []
jinja2 [] []
airflow.utils.log.colored_log [] []
airflow.api.common.experimental.get_task [] []
airflow.kubernetes.pod_launcher [] []
contextlib [] []
airflow.models [] []
airflow.migrations.versions.0119_2_4_3_add_case_insensitive_unique_constraint_for_username [] []
airflow.www.extensions.init_jinja_globals [] []
airflow.api_connexion.endpoints.log_endpoint [] []
pathlib [] []
airflow.operators.branch [] []
airflow.migrations.versions.0070_2_0_0_fix_mssql_exec_date_rendered_task_instance [] []
airflow.providers.imap.sensors [] []
airflow.models.operator [] []
airflow.example_dags.example_passing_params_via_test_command [] []
airflow.models.xcom [] []
airflow.contrib.hooks [] []
airflow.migrations.versions.0106_2_3_0_update_migration_for_fab_tables_to_add_missing_constraints [] []
airflow.api_connexion.schemas.connection_schema [] []
airflow.utils.mixins [] []
airflow.hooks.subprocess [] []
airflow.models.pool [] []
airflow.utils.session [] []
airflow.api.common.experimental.get_code [] []
airflow.models.expandinput [] []
airflow.cli.commands.jobs_command [] []
airflow.www.widgets [] []
airflow.api_internal.endpoints [] []
airflow.kubernetes.kube_config [] []
inspect [] []
airflow.example_dags.example_task_group [] []
airflow.api_connexion.schemas.provider_schema [] []
airflow.example_dags.example_branch_operator_decorator [] []
airflow.example_dags.example_branch_day_of_week_operator [] []
airflow.example_dags.example_short_circuit_operator [] []
airflow.providers.http.sensors.http [] []
airflow.cli.commands.celery_command [] []
lazy_object_proxy [] []
airflow.contrib [] []
airflow.api_connexion.schemas.user_schema [] []
airflow.operators.subdag [] []
slugify [] []
attr [] []
airflow.hooks.filesystem [] []
airflow.example_dags.example_task_group_decorator [] []
airflow.providers.http.sensors [] []
airflow.migrations.versions.0044_1_10_7_add_serialized_dag_table [] []
airflow.executors.local_executor [] []
deprecated [] []
traceback [] []
airflow.www.security [] []
airflow.migrations.versions.0045_1_10_7_add_root_dag_id_to_dag [] []
airflow.migrations.versions.0121_2_5_0_add_dagrunnote_and_taskinstancenote [] []
cryptography [] []
airflow.utils.log.non_caching_file_handler [] []
airflow.sensors.time_delta [] []
airflow.www.api [] []
airflow.decorators [] []
airflow.utils.dag_parsing_context [] []
airflow.migrations.versions.0077_2_0_0_change_field_in_dagcode_to_mediumtext_ [] []
airflow.operators.smooth [] []
airflow.migrations.versions.0047_1_10_4_increase_queue_name_size_limit [] []
airflow.utils.retries [] []
airflow.api_internal.internal_api_call [] []
airflow.api_connexion.parameters [] []
airflow.dag_processing.processor ['dag_fuzz'] []
airflow.migrations.versions.0020_1_7_1_xcom_dag_task_indices [] []
airflow [] []
airflow.kubernetes.pod_generator_deprecated [] []
packaging [] []
airflow.cli.commands.standalone_command [] []
airflow.example_dags.example_dynamic_task_mapping [] []
airflow.migrations.versions.0056_1_10_12_add_dag_hash_column_to_serialized_dag_ [] []
airflow.www.fab_security.sqla [] []
airflow.www.decorators [] []
airflow.migrations.versions.0120_2_5_0_add_updated_at_to_dagrun_and_ti [] []
sqlalchemy [] []
airflow.utils.configuration [] []
airflow.api_connexion.endpoints.extra_link_endpoint [] []
airflow.migrations.versions.0110_2_3_2_add_cascade_to_dag_tag_foreignkey [] []
airflow.example_dags.example_branch_datetime_operator [] []
airflow.api_connexion.schemas.sla_miss_schema [] []
airflow.cli.commands.kubernetes_command [] []
airflow.cli.commands.dag_command [] []
airflow.decorators.python_virtualenv [] []
airflow.ti_deps.deps.valid_state_dep [] []
textwrap [] []
airflow.cli.commands.legacy_commands [] []
airflow.secrets.metastore [] []
zipfile [] []
werkzeug [] []
airflow.migrations.versions.0053_1_10_10_add_rendered_task_instance_fields_table [] []
airflow.ti_deps.dependencies_states [] []
airflow.migrations.versions.0052_1_10_10_add_pool_slots_field_to_task_instance [] []
airflow.jobs.backfill_job [] []
fnmatch [] []
airflow.sensors.bash [] []
airflow.migrations.versions.0064_2_0_0_add_unique_constraint_to_conn_id [] []
airflow.serialization [] []
airflow.models.trigger [] []
airflow.sensors.base [] []
airflow.www.utils [] []
airflow.security [] []
airflow.www.extensions.init_appbuilder_links [] []
airflow.utils.log.file_processor_handler [] []
airflow.example_dags.subdags.subdag [] []
airflow.utils.python_virtualenv [] []
airflow.api [] []
airflow.utils.log.json_formatter [] []
airflow.api.common.delete_dag [] []
airflow.listeners [] []
airflow.migrations.versions.0087_2_1_4_add_index_on_state_dag_id_for_queued_ [] []
statsd [] []
airflow.migrations.versions.0068_2_0_0_drop_kuberesourceversion_and_ [] []
airflow.migrations.versions.0118_2_4_2_add_missing_autoinc_fab [] []
airflow.api_connexion.endpoints.role_and_permission_endpoint [] []
airflow.migrations.versions.0069_2_0_0_add_scheduling_decision_to_dagrun_and_ [] []
airflow.www.extensions.init_manifest_files [] []
airflow.api.common.experimental.delete_dag [] []
airflow.sensors [] []
airflow.jobs.local_task_job [] []
airflow._vendor [] []
airflow.www.extensions.init_security [] []
airflow.task.task_runner.standard_task_runner [] []
airflow.api_connexion.schemas.job_schema [] []
airflow.api_connexion.endpoints.dataset_endpoint [] []
airflow.utils.log.logging_mixin [] []
airflow.kubernetes.volume [] []
airflow.cli.commands.pool_command [] []
concurrent [] []
airflow.migrations.versions.0117_2_4_0_add_processor_subdir_to_dagmodel_and_ [] []
airflow.api_connexion.schemas [] []
airflow.operators.trigger_dagrun [] []
airflow.config_templates [] []
importlib_resources [] []
airflow.utils.log.file_task_handler ['dag_fuzz'] []
airflow.migrations.versions.0043_1_10_4_make_taskinstance_pool_not_nullable [] []
airflow.www.api.experimental [] []
airflow.api.client.local_client [] []
time [] []
airflow.www.fab_security.sqla.manager [] []
airflow.migrations.versions.0093_2_2_0_taskinstance_keyed_to_dagrun [] []
airflow.providers.common.sql.hooks [] []
airflow.example_dags.example_branch_operator [] []
airflow.utils.event_scheduler [] []
airflow.security.kerberos [] []
airflow.models.dagpickle [] []
pty [] []
airflow.providers.ftp.sensors.ftp [] []
multiprocessing [] []
airflow.triggers [] []
gzip [] []
airflow_local_settings [] []
airflow.migrations.versions.0076_2_0_0_fix_description_field_in_connection_to_ [] []
airflow.migrations.versions.0012_1_7_0_add_notification_sent_column_to_sla_miss [] []
airflow.models.taskreschedule [] []
setproctitle [] []
airflow.migrations.versions.0016_1_7_1_add_ti_state_index [] []
airflow.providers.common.sql.operators [] []
secrets [] []
airflow.triggers.base [] []
airflow.www.extensions.init_views [] []
airflow.operators.email [] []
airflow.migrations.versions.0116_2_4_0_add_dag_owner_attributes_table [] []
airflow.providers.common.sql.operators.sql [] []
decimal [] []
airflow.sensors.external_task [] []
airflow.migrations.versions.0021_1_7_1_add_pid_field_to_taskinstance [] []
alembic [] []
airflow.api_connexion.schemas.trigger_schema [] []
airflow.api_connexion.endpoints.event_log_endpoint [] []
airflow.providers.http.operators.http [] []
airflow.api_connexion.endpoints.health_endpoint [] []
airflow.api_connexion.schemas.task_schema [] []
airflow.providers.sqlite.operators.sqlite [] []
airflow.providers.imap.sensors.imap_attachment [] []
airflow.migrations.versions.0122_2_5_0_add_is_orphaned_to_datasetmodel [] []
airflow.migrations.versions.0100_2_3_0_add_taskmap_and_map_id_on_taskinstance [] []
airflow.ti_deps.deps.task_not_running_dep [] []
airflow.utils.module_loading [] []
re [] []
flask_appbuilder [] []
airflow.api_connexion.endpoints.pool_endpoint [] []
airflow.models.errors [] []
airflow.api.client [] []
pathspec [] []
airflow.migrations.versions.0038_1_10_2_add_sm_dag_index [] []
airflow.utils.platform [] []
tempfile [] []
airflow.cli.commands.sync_perm_command [] []
airflow.www.api.experimental.endpoints [] []
airflow.migrations.versions.0097_2_3_0_increase_length_of_email_and_username [] []
airflow.kubernetes.kubernetes_helper_functions [] []
flask_babel [] []
airflow.api_connexion.exceptions [] []
airflow.migrations.versions.0063_2_0_0_set_conn_type_as_non_nullable [] []
airflow.migrations.versions.0050_1_10_7_increase_length_for_connection_password [] []
airflow.example_dags.example_complex [] []
airflow.migrations.utils [] []
airflow.example_dags.example_local_kubernetes_executor [] []
airflow.timetables.base [] []
airflow.migrations.versions.0078_2_0_1_remove_can_read_permission_on_config_ [] []
airflow.api.client.api_client [] []
airflow.models.variable [] []
airflow.utils.log.task_handler_with_custom_formatter [] []
airflow.ti_deps.deps.exec_date_after_start_date_dep [] []
types [] []
httpx [] []
airflow.www.fab_security.manager [] []
airflow.providers.http.get_provider_info [] []
airflow.migrations.versions.0085_2_1_3_add_queued_at_column_to_dagrun_table [] []
airflow.utils.compression [] []
platform [] []
airflow.cli.commands.triggerer_command [] []
airflow.cli.commands.role_command [] []
airflow.models.slamiss [] []
airflow.example_dags.subdags [] []
airflow.sensors.weekday [] []
airflow.migrations.versions.0094_2_2_3_add_has_import_errors_column_to_dagmodel [] []
airflow.migrations.versions.0109_2_3_1_add_index_for_event_in_log [] []
airflow.operators.python [] []
airflow.utils.cli [] []
airflow.cli.commands.scheduler_command [] []
airflow.exceptions ['dag_fuzz'] []
airflow.migrations.versions.0004_1_5_0_more_logging_into_task_isntance [] []
pprint [] []
argcomplete [] []
airflow.providers.common.sql.hooks.sql [] []
airflow.utils.log [] []
pendulum [] []
airflow.api_connexion.endpoints.dag_source_endpoint [] []
airflow.callbacks [] []
airflow.models.abstractoperator [] []
airflow.security.utils [] []
airflow.models.xcom_arg [] []
json [] []
airflow.cli.commands.task_command [] []
termios [] []
airflow.kubernetes.k8s_model [] []
base64 [] []
airflow.macros [] []
datetime [] []
airflow.listeners.events [] []
airflow.migrations.versions.0095_2_2_4_add_session_table_to_db [] []
airflow.migrations.versions.0036_1_10_2_add_index_to_taskinstance [] []
airflow.migrations.versions.0057_1_10_13_add_fab_tables [] []
airflow.migrations.versions.0086_2_1_4_add_max_active_runs_column_to_dagmodel_ [] []
airflow.utils.trigger_rule [] []
airflow.providers.http.hooks.http [] []
itsdangerous [] []
airflow.migrations.versions.0059_2_0_0_drop_user_and_chart [] []
yaml [] []
airflow.task [] []
shlex [] []
airflow.migrations.versions.0046_1_10_5_change_datetime_to_datetime2_6_on_mssql_ [] []
airflow.cli.commands.plugins_command [] []
airflow.example_dags [] []
flask_login [] []
airflow.cli.commands.variable_command [] []
cattr [] []
airflow.utils.dates ['dag_fuzz'] []
airflow.utils.operator_helpers [] []
zlib [] []
airflow.providers.sqlite.operators [] []
airflow.stats [] []
airflow.migrations.versions.0089_2_2_0_make_xcom_pkey_columns_non_nullable [] []
configupdater [] []
airflow.serialization.serializers.kubernetes [] []
marshmallow_sqlalchemy [] []
airflow.sensors.filesystem [] []
airflow.ti_deps.deps.base_ti_dep [] []
colorlog [] []
airflow.migrations.versions.0058_1_10_13_increase_length_of_fab_ab_view_menu_ [] []
airflow.secrets [] []
airflow.api_connexion.schemas.dag_run_schema [] []
airflow.utils.airflow_flask_app [] []
bisect [] []
airflow.sensors.time_sensor [] []
airflow.cli.commands.cheat_sheet_command [] []
airflow.callbacks.pipe_callback_sink [] []
random [] []
airflow.migrations.versions.0041_1_10_3_add_schedule_interval_to_dag [] []
airflow.example_dags.example_trigger_controller_dag [] []
airflow.example_dags.example_sensor_decorator [] []
airflow.api.common.experimental.mark_tasks [] []
flask_sqlalchemy [] []
airflow.executors [] []
select [] []
uuid [] []
airflow.migrations.versions.0060_2_0_0_remove_id_column_from_xcom [] []
airflow.providers.ftp [] []
airflow.kubernetes.pod_runtime_info_env [] []
airflow.example_dags.tutorial_taskflow_api [] []
airflow.utils.dag_cycle_tester [] []
airflow.kubernetes.secret [] []
sentry_sdk [] []
airflow.www.extensions [] []
airflow.api_connexion.endpoints.dag_run_endpoint [] []
airflow.config_templates.default_webserver_config [] []
airflow.providers_manager [] []
airflow.api_connexion.endpoints.task_endpoint [] []
airflow.api.common.mark_tasks [] []
requests_toolbelt [] []
imaplib [] []
airflow.migrations.versions.0090_2_2_0_rename_concurrency_column_in_dag_table_ [] []
airflow.www.session [] []
airflow.www.validators [] []
airflow.example_dags.example_latest_only_with_trigger [] []
airflow.ti_deps.dep_context [] []
threading [] []
airflow.utils.net [] []
airflow.models.dataset [] []
croniter [] []
airflow.executors.dask_executor [] []
http [] []
airflow.api_connexion.schemas.pool_schema [] []
airflow.utils.file [] []
connexion [] []
airflow.decorators.short_circuit [] []
airflow.executors.executor_constants [] []
argparse [] []
airflow.decorators.task_group [] []
airflow.migrations.versions.0029_1_10_0_add_executor_config_to_task_instance [] []
airflow.utils.log.timezone_aware [] []
flask_jwt_extended [] []
airflow.jobs.triggerer_job [] []
airflow.example_dags.plugins [] []
flask [] []
airflow.ti_deps.deps [] []
airflow.operators.empty [] []
airflow.dag_processing [] []
flask_wtf [] []
airflow.migrations.versions.0040_1_10_3_add_fields_to_dag [] []
airflow.executors.debug_executor [] []
airflow.providers.sqlite.hooks [] []
airflow.example_dags.tutorial [] []
airflow.api_connexion.schemas.event_log_schema [] []
airflow.migrations.versions.0099_2_3_0_add_task_log_filename_template_model [] []
airflow.cli.commands.connection_command [] []
airflow.listeners.spec.dagrun [] []
airflow.cli.commands.version_command [] []
[] []
airflow.api_connexion.schemas.error_schema [] []
airflow.api.client.json_client [] []
airflow.lineage [] []
requests_kerberos [] []
airflow.utils.docs [] []
airflow.migrations.versions.0113_2_4_0_compare_types_between_orm_and_db [] []
airflow.api_connexion.endpoints.task_instance_endpoint [] []
airflow.jobs.base_job [] []
airflow.utils [] []
airflow.migrations.versions.0066_2_0_0_add_queued_by_job_id_to_ti [] []
airflow.serialization.serializers.timezone [] []
airflow.migrations.versions.0054_1_10_10_add_dag_code_table [] []
airflow.www.views [] []
airflow.www.gunicorn_config [] []
ldap [] []
airflow.ti_deps.deps.runnable_exec_date_dep [] []
airflow.ti_deps.deps.task_concurrency_dep [] []
tabulate [] []
airflow.migrations.db_types [] []
airflow.ti_deps.deps.dag_unpaused_dep [] []
airflow.www.extensions.init_dagbag [] []
airflow.__main__ [] []
airflow.cli.commands.dag_processor_command [] []
airflow.models.renderedtifields [] []
airflow.cli.cli_parser [] []
airflow.api.auth.backend.default [] []
airflow.api.common.experimental.get_dag_runs [] []
airflow.api.common.experimental.trigger_dag [] []
airflow.cli [] []
airflow.api.auth [] []
colorlog.colorlog [] []
glob [] []

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

Function call coverage

This section shows a chosen list of functions / methods calls and their relative coverage information. By static analysis of the target project code, all of these function call and their caller information, including the source file or class and line number that initiate the call are captured. The caller source code file or class and the line number are shown in column 2 while column 1 is the function name of that selected functions or methods call. Each occurrent of the target function call will occuply a separate row. Column 3 of each row indicate if the target function calls is statically unreachable.Column 4 lists all fuzzers (or no fuzzers at all) that have covered that particular system call in dynamic fuzzing. Those functions with low to no reachability and dynamic hit count indicate missed fuzzing logic to fuzz and track for possible code injection sinks.

Function in each files in report

Target sink Callsite location Reached by fuzzer