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 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

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 .TypeError [function] [call site] 00022
2 copy.deepcopy [function] [call site] 00023
2 params.update [function] [call site] 00024
2 airflow.models.param.ParamsDict.__init__ [function] [call site] 00025
3 airflow.models.log.Text.items [function] [call site] 00026
3 airflow.models.variable.Boolean.items [function] [call site] 00027
3 airflow.models.dataset.Integer.items [function] [call site] 00028
3 airflow.models.dagrun.Boolean.items [function] [call site] 00029
3 airflow.models.dag.Boolean.items [function] [call site] 00030
3 datetime.timedelta.dag.dag_id.items [function] [call site] 00031
3 typing.NamedTuple.parent_dag.dag_id.items [function] [call site] 00032
3 sqlalchemy.dialects.mssql.DATETIME2.items [function] [call site] 00033
3 datetime.timedelta.priority_weight_total.items [function] [call site] 00034
3 sqlalchemy.BigInteger.items [function] [call site] 00035
3 airflow.models.taskreschedule.Integer.items [function] [call site] 00036
3 sqlalchemy.UniqueConstraint.items [function] [call site] 00037
3 airflow.www.fab_security.sqla.models.DateTime.items [function] [call site] 00038
3 typing.NamedTuple.items [function] [call site] 00039
3 datetime.timedelta.task_id.items [function] [call site] 00040
3 sqlalchemy.PickleType.items [function] [call site] 00041
3 airflow.www.fab_security.sqla.models.Integer.items [function] [call site] 00042
3 typing.NamedTuple.task_id.items [function] [call site] 00043
3 airflow.migrations.versions.0102_2_3_0_switch_xcom_table_to_use_run_id.Integer.items [function] [call site] 00044
3 airflow.models.connection.Boolean.items [function] [call site] 00045
3 sqlalchemy.DateTime.items [function] [call site] 00046
3 sqlalchemy.LargeBinary.items [function] [call site] 00047
3 airflow.models.dagwarning.Text.items [function] [call site] 00048
3 airflow.migrations.versions.0023_1_8_2_add_max_tries_column_to_task_instance.Integer.items [function] [call site] 00049
3 typing.NamedTuple.priority_weight_total.items [function] [call site] 00050
3 airflow.models.pool.Integer.items [function] [call site] 00051
3 airflow.models.taskinstance.Integer.items [function] [call site] 00052
3 airflow.models.renderedtifields.Integer.items [function] [call site] 00053
3 airflow.migrations.versions.0062_2_0_0_add_dagrun_run_type.Integer.items [function] [call site] 00054
3 airflow.jobs.base_job.Integer.items [function] [call site] 00055
3 airflow.models.tasklog.Text.items [function] [call site] 00056
3 airflow.models.dagrun.Integer.items [function] [call site] 00057
3 airflow.models.pool.Text.items [function] [call site] 00058
3 airflow.models.taskinstance.Float.items [function] [call site] 00059
3 airflow.www.fab_security.sqla.models.Boolean.items [function] [call site] 00060
3 sqlalchemy.Column.items [function] [call site] 00061
3 airflow.models.dagcode.BigInteger.items [function] [call site] 00062
3 airflow.models.tasklog.Integer.items [function] [call site] 00063
3 airflow.models.taskfail.Integer.items [function] [call site] 00064
3 datetime.timedelta.parent_dag.dag_id.items [function] [call site] 00065
3 airflow.models.serialized_dag.LargeBinary.items [function] [call site] 00066
3 airflow.models.trigger.Integer.items [function] [call site] 00067
3 airflow.migrations.versions.0099_2_3_0_add_task_log_filename_template_model.Text.items [function] [call site] 00068
3 airflow.models.dagrun.PickleType.items [function] [call site] 00069
3 airflow.models.errors.Integer.items [function] [call site] 00070
3 airflow.models.errors.Text.items [function] [call site] 00071
3 datetime.timedelta.dag_id.items [function] [call site] 00072
3 airflow.models.slamiss.Boolean.items [function] [call site] 00073
3 sqlalchemy.Integer.items [function] [call site] 00074
3 airflow.models.log.Integer.items [function] [call site] 00075
3 airflow.models.variable.Integer.items [function] [call site] 00076
3 airflow.models.dataset.Boolean.items [function] [call site] 00077
3 airflow.migrations.versions.0102_2_3_0_switch_xcom_table_to_use_run_id.LargeBinary.items [function] [call site] 00078
3 airflow.migrations.versions.0099_2_3_0_add_task_log_filename_template_model.Integer.items [function] [call site] 00079
3 airflow.models.dag.Text.items [function] [call site] 00080
3 sqlalchemy.Float.items [function] [call site] 00081
3 airflow.models.dagpickle.BigInteger.items [function] [call site] 00082
3 sqlalchemy.TIMESTAMP.items [function] [call site] 00083
3 airflow.models.taskinstance.DateTime.items [function] [call site] 00084
3 airflow.models.taskmap.Integer.items [function] [call site] 00085
3 airflow.models.dagpickle.Integer.items [function] [call site] 00086
3 airflow.models.dag.Integer.items [function] [call site] 00087
3 sqlalchemy.String.items [function] [call site] 00088
3 airflow.models.param.ParamsDict.items [function] [call site] 00089
4 typing.ItemsView [function] [call site] 00090
3 airflow.models.variable.Text.items [function] [call site] 00091
3 sqlalchemy.Boolean.items [function] [call site] 00092
3 datetime.timedelta.items [function] [call site] 00093
3 airflow.migrations.versions.0114_2_4_0_add_dataset_model.Integer.items [function] [call site] 00094
3 airflow.models.xcom.LargeBinary.items [function] [call site] 00095
3 sqlalchemy.Text.items [function] [call site] 00096
3 datetime.timedelta.subdags.parent_dag.dag_id.items [function] [call site] 00097
3 airflow.models.slamiss.Text.items [function] [call site] 00098
3 airflow.migrations.versions.0107_2_3_0_add_map_index_to_log.Integer.items [function] [call site] 00099
3 sqlalchemy.types.TypeDecorator.items [function] [call site] 00100
3 typing.NamedTuple.subdags.parent_dag.dag_id.items [function] [call site] 00101
3 sqlalchemy.ForeignKey.items [function] [call site] 00102
3 airflow.migrations.versions.0100_2_3_0_add_taskmap_and_map_id_on_taskinstance.Integer.items [function] [call site] 00103
3 typing.NamedTuple.dag_id.items [function] [call site] 00104
3 .isinstance [function] [call site] 00105
3 airflow.models.param.Param.__init__ [function] [call site] 00106
4 airflow.models.param.Param._warn_if_not_json [function] [call site] 00107
5 json.dumps [function] [call site] 00108
5 warnings.warn [function] [call site] 00109
4 kwargs.pop [function] [call site] 00110
2 warnings.warn [function] [call site] 00111
2 airflow.utils.helpers.validate_key [function] [call site] 00112
2 warnings.warn [function] [call site] 00118
2 sys._getframe [function] [call site] 00119
2 pendulum.instance [function] [call site] 00120
2 .isinstance [function] [call site] 00121
2 timezone.parse [function] [call site] 00122
2 pendulum.instance [function] [call site] 00123
2 .isinstance [function] [call site] 00124
2 timezone.parse [function] [call site] 00125
2 timezone.convert_to_utc [function] [call site] 00126
2 timezone.convert_to_utc [function] [call site] 00127
2 timezone.convert_to_utc [function] [call site] 00128
2 timezone.convert_to_utc [function] [call site] 00129
2 airflow.utils.helpers.at_most_one [function] [call site] 00130
2 .ValueError [function] [call site] 00133
2 warnings.warn [function] [call site] 00134
2 warnings.warn [function] [call site] 00135
2 .isinstance [function] [call site] 00136
2 .isinstance [function] [call site] 00137
2 .isinstance [function] [call site] 00138
2 .ValueError [function] [call site] 00140
2 .isinstance [function] [call site] 00142
2 typing.Protocol.__init__ [function] [call site] 00143
2 .isinstance [function] [call site] 00144
2 airflow.models.dag.create_timetable [function] [call site] 00145
3 airflow.models.xcom.Any [function] [call site] 00146
3 typing.TypeVar [function] [call site] 00147
3 airflow.utils.log.file_task_handler.FileTaskHandler.__init__ [function] [call site] 00148
3 airflow.timetables.interval.DeltaDataIntervalTimetable.__init__ [function] [call site] 00152
3 typing.Any [function] [call site] 00153
3 typing.TypedDict.__init__ [function] [call site] 00154
3 airflow.typing_compat.TypedDict.__init__ [function] [call site] 00155
3 typing_extensions.TypedDict.__init__ [function] [call site] 00156
3 airflow.typing_compat.Protocol.__init__ [function] [call site] 00157
3 typing.Protocol.__init__ [function] [call site] 00158
3 typing_extensions.Protocol.__init__ [function] [call site] 00159
3 .isinstance [function] [call site] 00160
3 airflow.models.xcom.Any [function] [call site] 00161
3 typing.TypeVar [function] [call site] 00162
3 airflow.utils.log.file_task_handler.FileTaskHandler.__init__ [function] [call site] 00163
3 airflow.timetables.interval.DeltaDataIntervalTimetable.__init__ [function] [call site] 00164
3 typing.Any [function] [call site] 00165
3 typing_extensions.TypedDict.__init__ [function] [call site] 00166
3 .isinstance [function] [call site] 00167
3 airflow.timetables._cron.CronMixin.__init__ [function] [call site] 00168
4 cron_descriptor.FormatException [function] [call site] 00169
4 cron_presets.get [function] [call site] 00170
4 .isinstance [function] [call site] 00171
4 pendulum.tz.timezone.Timezone [function] [call site] 00172
4 cron_descriptor.ExpressionDescriptor [function] [call site] 00173
4 croniter.croniter [function] [call site] 00174
4 cron_descriptor.FormatException [function] [call site] 00176
4 cron_descriptor.ExpressionDescriptor.get_description [function] [call site] 00177
3 airflow.models.xcom.Any [function] [call site] 00178
3 typing.TypeVar [function] [call site] 00179
3 airflow.dag_processing.processor.DagFileProcessorProcess.__init__ [function] [call site] 00180
3 airflow.utils.log.file_task_handler.FileTaskHandler.__init__ [function] [call site] 00182
3 airflow.timetables.interval.DeltaDataIntervalTimetable.__init__ [function] [call site] 00183
3 sqlalchemy.orm.query.Query [function] [call site] 00184
3 typing.Any [function] [call site] 00185
3 typing_extensions.TypedDict.__init__ [function] [call site] 00186
3 .ValueError [function] [call site] 00187
2 .isinstance [function] [call site] 00188
2 timezone.utcnow [function] [call site] 00189
2 dag_id.replace [function] [call site] 00190
2 warnings.warn [function] [call site] 00191
2 airflow.models.dag.DAG._upgrade_outdated_dag_access_control [function] [call site] 00192
3 access_control.items [function] [call site] 00193
3 new_perm_mapping.get [function] [call site] 00194
3 warnings.warn [function] [call site] 00195
2 airflow.models.dag.DAG.get_doc_md [function] [call site] 00196
3 airflow.models.dag.DAG.get_template_env [function] [call site] 00197
4 jinja2.FileSystemLoader [function] [call site] 00198
4 jinja_env_options.update [function] [call site] 00199
4 airflow.templates.NativeEnvironment [function] [call site] 00200
4 airflow.templates.SandboxedEnvironment [function] [call site] 00201
4 env.globals.update [function] [call site] 00202
4 env.filters.update [function] [call site] 00203
3 doc_md.endswith [function] [call site] 00204
3 jinja2.Template [function] [call site] 00205
3 env.get_template [function] [call site] 00206
3 template.render [function] [call site] 00207
2 airflow.utils.task_group.TaskGroup.create_root [function] [call site] 00208
3 airflow.utils.task_group.TaskGroup.__init__ [function] [call site] 00209
4 copy.deepcopy [function] [call site] 00210
4 airflow.models.dag.DagContext.get_current_dag [function] [call site] 00211
4 airflow.utils.helpers.validate_group_key [function] [call site] 00213
5 .isinstance [function] [call site] 00214
5 .TypeError [function] [call site] 00216
5 GROUP_KEY_REGEX.match [function] [call site] 00218
4 .isinstance [function] [call site] 00219
4 .ValueError [function] [call site] 00220
4 .ValueError [function] [call site] 00221
4 airflow.utils.task_group.TaskGroupContext.get_current_task_group [function] [call site] 00222
5 airflow.models.dag.DagContext.get_current_dag [function] [call site] 00223
4 .RuntimeError [function] [call site] 00224
4 airflow.utils.task_group.TaskGroup._check_for_group_id_collisions [function] [call site] 00225
4 airflow.utils.task_group.TaskGroup.add [function] [call site] 00231
5 airflow.exceptions.TaskAlreadyInTaskGroup.__init__ [function] [call site] 00232
5 .isinstance [function] [call site] 00234
5 airflow.exceptions.TaskAlreadyInTaskGroup.__init__ [function] [call site] 00235
5 weakref.proxy [function] [call site] 00236
5 .isinstance [function] [call site] 00238
5 .RuntimeError [function] [call site] 00239
2 airflow.models.dag.DAG.validate_schedule_and_params [function] [call site] 00244
3 airflow.models.param.ParamsDict.items [function] [call site] 00245
2 airflow.models.dag.DAG.iter_invalid_owner_links [function] [call site] 00246
3 urllib.parse.urlsplit [function] [call site] 00247
1 fdp.ConsumeString [function] [call site] 00249
1 fdp.ConsumeIntInRange [function] [call site] 00250
1 airflow.operators.dummy_operator.DummyOperator [function] [call site] 00251
1 fdp.ConsumeString [function] [call site] 00252
1 airflow.operators.python_operator.PythonOperator [function] [call site] 00253