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

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: {node_id} airflow.models.dag.DAG.get_template_env
7 25 airflow.models.param.ParamsDict.__init__ call site: {node_id} airflow.models.param.Param.__init__
6 12 ...dag_fuzz.TestInput call site: {node_id} airflow.models.dag.DAG.__init__
6 103 airflow.utils.task_group.TaskGroup.__init__ call site: {node_id} airflow.utils.helpers.validate_group_key
6 111 airflow.utils.task_group.TaskGroup.__init__ call site: {node_id} airflow.utils.task_group.TaskGroup.add
5 62 airflow.models.dag.DAG.__init__ call site: {node_id} airflow.timetables.interval.DeltaDataIntervalTimetable.__init__
5 132 airflow.models.dag.DAG.__init__ call site: {node_id} fdp.ConsumeString
3 55 airflow.models.dag.DAG.__init__ call site: {node_id} .isinstance
3 83 airflow.models.dag.DAG.__init__ call site: {node_id} access_control.items
2 42 airflow.models.dag.DAG.__init__ call site: {node_id} .isinstance
1 0 EP call site: {node_id} atheris.FuzzedDataProvider
1 10 airflow.utils.dates.days_ago call site: {node_id} fdp.ConsumeString

Fuzzer calltree

0 ...dag_fuzz.TestInput [function] [call site] 00000
1 atheris.FuzzedDataProvider [function] [call site] 00001
1 fdp.ConsumeString [function] [call site] 00002
1 fdp.ConsumeBool [function] [call site] 00003
1 fdp.ConsumeIntInRange [function] [call site] 00004
1 airflow.utils.dates.days_ago [function] [call site] 00005
2 warnings.warn [function] [call site] 00006
2 airflow.utils.timezone.utcnow [function] [call site] 00007
3 datetime.datetime.utcnow [function] [call site] 00008
3 result.replace [function] [call site] 00009
2 datetime.timedelta [function] [call site] 00010
1 fdp.ConsumeString [function] [call site] 00011
1 fdp.ConsumeBool [function] [call site] 00012
1 fdp.ConsumeBool [function] [call site] 00013
1 fdp.ConsumeIntInRange [function] [call site] 00014
1 fdp.ConsumeIntInRange [function] [call site] 00015
1 datetime.timedelta [function] [call site] 00016
1 fdp.ConsumeString [function] [call site] 00017
1 airflow.models.dag.DAG.__init__ [function] [call site] 00018
2 .isinstance [function] [call site] 00021
2 copy.deepcopy [function] [call site] 00022
2 params.update [function] [call site] 00023
2 airflow.models.param.ParamsDict.__init__ [function] [call site] 00024
3 dict_obj.items [function] [call site] 00025
3 .isinstance [function] [call site] 00026
3 airflow.models.param.Param.__init__ [function] [call site] 00027
4 airflow.models.param.Param._warn_if_not_json [function] [call site] 00028
5 json.dumps [function] [call site] 00029
5 warnings.warn [function] [call site] 00030
4 kwargs.pop [function] [call site] 00031
2 warnings.warn [function] [call site] 00032
2 airflow.utils.helpers.validate_key [function] [call site] 00033
3 .isinstance [function] [call site] 00034
3 KEY_REGEX.match [function] [call site] 00036
2 warnings.warn [function] [call site] 00037
2 sys._getframe [function] [call site] 00038
2 pendulum.instance [function] [call site] 00039
2 .isinstance [function] [call site] 00040
2 timezone.parse [function] [call site] 00041
2 pendulum.instance [function] [call site] 00042
2 .isinstance [function] [call site] 00043
2 timezone.parse [function] [call site] 00044
2 timezone.convert_to_utc [function] [call site] 00045
2 timezone.convert_to_utc [function] [call site] 00046
2 timezone.convert_to_utc [function] [call site] 00047
2 timezone.convert_to_utc [function] [call site] 00048
2 airflow.utils.helpers.at_most_one [function] [call site] 00049
2 warnings.warn [function] [call site] 00052
2 warnings.warn [function] [call site] 00053
2 .isinstance [function] [call site] 00054
2 .isinstance [function] [call site] 00055
2 .isinstance [function] [call site] 00056
2 .isinstance [function] [call site] 00059
2 airflow.typing_compat.Protocol.__init__ [function] [call site] 00060
2 .isinstance [function] [call site] 00061
2 airflow.models.dag.create_timetable [function] [call site] 00062
3 airflow.timetables.interval.DeltaDataIntervalTimetable.__init__ [function] [call site] 00063
3 typing.Protocol.__init__ [function] [call site] 00064
3 airflow.typing_compat.Protocol.__init__ [function] [call site] 00065
3 airflow.typing_compat.Protocol.__init__ [function] [call site] 00066
3 airflow.typing_compat.Protocol.__init__ [function] [call site] 00067
3 .isinstance [function] [call site] 00068
3 airflow.timetables.interval.DeltaDataIntervalTimetable.__init__ [function] [call site] 00069
3 .isinstance [function] [call site] 00070
3 airflow.timetables._cron.CronMixin.__init__ [function] [call site] 00071
4 cron_presets.get [function] [call site] 00072
4 .isinstance [function] [call site] 00073
4 pendulum.tz.timezone.Timezone [function] [call site] 00074
4 cron_descriptor.ExpressionDescriptor [function] [call site] 00075
4 croniter.croniter [function] [call site] 00076
4 cron_descriptor.ExpressionDescriptor.get_description [function] [call site] 00078
2 .isinstance [function] [call site] 00079
2 timezone.utcnow [function] [call site] 00080
2 pathlib.Path.stem.replace [function] [call site] 00081
2 warnings.warn [function] [call site] 00082
2 airflow.models.dag.DAG._upgrade_outdated_dag_access_control [function] [call site] 00083
3 access_control.items [function] [call site] 00084
3 new_perm_mapping.get [function] [call site] 00085
3 warnings.warn [function] [call site] 00086
2 airflow.models.dag.DAG.get_doc_md [function] [call site] 00087
3 airflow.models.dag.DAG.get_template_env [function] [call site] 00088
4 jinja2.FileSystemLoader [function] [call site] 00089
4 jinja_env_options.update [function] [call site] 00090
4 airflow.templates.NativeEnvironment [function] [call site] 00091
4 airflow.templates.SandboxedEnvironment [function] [call site] 00092
4 env.globals.update [function] [call site] 00093
4 env.filters.update [function] [call site] 00094
3 doc_md.endswith [function] [call site] 00095
3 jinja2.Template [function] [call site] 00096
3 env.get_template [function] [call site] 00097
3 template.render [function] [call site] 00098
2 airflow.utils.task_group.TaskGroup.create_root [function] [call site] 00099
3 airflow.utils.task_group.TaskGroup.__init__ [function] [call site] 00100
4 copy.deepcopy [function] [call site] 00101
4 airflow.models.dag.DagContext.get_current_dag [function] [call site] 00102
4 airflow.utils.helpers.validate_group_key [function] [call site] 00104
5 .isinstance [function] [call site] 00105
5 GROUP_KEY_REGEX.match [function] [call site] 00107
4 .isinstance [function] [call site] 00108
4 airflow.utils.task_group.TaskGroupContext.get_current_task_group [function] [call site] 00109
5 airflow.models.dag.DagContext.get_current_dag [function] [call site] 00110
4 airflow.utils.task_group.TaskGroup._check_for_group_id_collisions [function] [call site] 00111
4 airflow.utils.task_group.TaskGroup.add [function] [call site] 00117
5 .isinstance [function] [call site] 00118
5 weakref.proxy [function] [call site] 00119
5 .isinstance [function] [call site] 00121
4 airflow.utils.task_group.TaskGroup._update_default_args [function] [call site] 00122
2 airflow.models.dag.DAG.validate_schedule_and_params [function] [call site] 00127
3 airflow.models.param.ParamsDict.items [function] [call site] 00128
4 typing.ItemsView [function] [call site] 00129
2 airflow.models.dag.DAG.iter_invalid_owner_links [function] [call site] 00130
3 urllib.parse.urlsplit [function] [call site] 00131
1 fdp.ConsumeString [function] [call site] 00133
1 fdp.ConsumeIntInRange [function] [call site] 00134
1 airflow.operators.dummy_operator.DummyOperator [function] [call site] 00135
1 fdp.ConsumeString [function] [call site] 00136
1 airflow.operators.python_operator.PythonOperator [function] [call site] 00137