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