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} |
|
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} |
|
1 | 0 | EP | call site: {node_id} | atheris.FuzzedDataProvider |
1 | 10 | airflow.utils.dates.days_ago | call site: {node_id} | fdp.ConsumeString |
...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
copy.deepcopy
[function]
[call site]
00022
params.update
[function]
[call site]
00023
airflow.models.param.ParamsDict.__init__
[function]
[call site]
00024
dict_obj.items
[function]
[call site]
00025
.isinstance
[function]
[call site]
00026
airflow.models.param.Param.__init__
[function]
[call site]
00027
airflow.models.param.Param._warn_if_not_json
[function]
[call site]
00028
json.dumps
[function]
[call site]
00029
warnings.warn
[function]
[call site]
00030
kwargs.pop
[function]
[call site]
00031
warnings.warn
[function]
[call site]
00032
airflow.utils.helpers.validate_key
[function]
[call site]
00033
.isinstance
[function]
[call site]
00034
.len
[function]
[call site]
00035
KEY_REGEX.match
[function]
[call site]
00036
warnings.warn
[function]
[call site]
00037
sys._getframe
[function]
[call site]
00038
pendulum.instance
[function]
[call site]
00039
.isinstance
[function]
[call site]
00040
timezone.parse
[function]
[call site]
00041
pendulum.instance
[function]
[call site]
00042
.isinstance
[function]
[call site]
00043
timezone.parse
[function]
[call site]
00044
timezone.convert_to_utc
[function]
[call site]
00045
timezone.convert_to_utc
[function]
[call site]
00046
timezone.convert_to_utc
[function]
[call site]
00047
timezone.convert_to_utc
[function]
[call site]
00048
airflow.utils.helpers.at_most_one
[function]
[call site]
00049
.map
[function]
[call site]
00050
.sum
[function]
[call site]
00051
warnings.warn
[function]
[call site]
00052
warnings.warn
[function]
[call site]
00053
.isinstance
[function]
[call site]
00054
.isinstance
[function]
[call site]
00055
.isinstance
[function]
[call site]
00056
.all
[function]
[call site]
00057
.list
[function]
[call site]
00058
.isinstance
[function]
[call site]
00059
airflow.typing_compat.Protocol.__init__
[function]
[call site]
00060
.isinstance
[function]
[call site]
00061
airflow.models.dag.create_timetable
[function]
[call site]
00062
airflow.timetables.interval.DeltaDataIntervalTimetable.__init__
[function]
[call site]
00063
typing.Protocol.__init__
[function]
[call site]
00064
airflow.typing_compat.Protocol.__init__
[function]
[call site]
00065
airflow.typing_compat.Protocol.__init__
[function]
[call site]
00066
airflow.typing_compat.Protocol.__init__
[function]
[call site]
00067
.isinstance
[function]
[call site]
00068
airflow.timetables.interval.DeltaDataIntervalTimetable.__init__
[function]
[call site]
00069
.isinstance
[function]
[call site]
00070
airflow.timetables._cron.CronMixin.__init__
[function]
[call site]
00071
cron_presets.get
[function]
[call site]
00072
.isinstance
[function]
[call site]
00073
pendulum.tz.timezone.Timezone
[function]
[call site]
00074
cron_descriptor.ExpressionDescriptor
[function]
[call site]
00075
croniter.croniter
[function]
[call site]
00076
.len
[function]
[call site]
00077
cron_descriptor.ExpressionDescriptor.get_description
[function]
[call site]
00078
.isinstance
[function]
[call site]
00079
timezone.utcnow
[function]
[call site]
00080
pathlib.Path.stem.replace
[function]
[call site]
00081
warnings.warn
[function]
[call site]
00082
airflow.models.dag.DAG._upgrade_outdated_dag_access_control
[function]
[call site]
00083
access_control.items
[function]
[call site]
00084
new_perm_mapping.get
[function]
[call site]
00085
warnings.warn
[function]
[call site]
00086
airflow.models.dag.DAG.get_doc_md
[function]
[call site]
00087
airflow.models.dag.DAG.get_template_env
[function]
[call site]
00088
jinja2.FileSystemLoader
[function]
[call site]
00089
jinja_env_options.update
[function]
[call site]
00090
airflow.templates.NativeEnvironment
[function]
[call site]
00091
airflow.templates.SandboxedEnvironment
[function]
[call site]
00092
env.globals.update
[function]
[call site]
00093
env.filters.update
[function]
[call site]
00094
doc_md.endswith
[function]
[call site]
00095
jinja2.Template
[function]
[call site]
00096
env.get_template
[function]
[call site]
00097
template.render
[function]
[call site]
00098
airflow.utils.task_group.TaskGroup.create_root
[function]
[call site]
00099
airflow.utils.task_group.TaskGroup.__init__
[function]
[call site]
00100
copy.deepcopy
[function]
[call site]
00101
airflow.models.dag.DagContext.get_current_dag
[function]
[call site]
00102
.set
[function]
[call site]
00103
airflow.utils.helpers.validate_group_key
[function]
[call site]
00104
.isinstance
[function]
[call site]
00105
.len
[function]
[call site]
00106
GROUP_KEY_REGEX.match
[function]
[call site]
00107
.isinstance
[function]
[call site]
00108
airflow.utils.task_group.TaskGroupContext.get_current_task_group
[function]
[call site]
00109
airflow.models.dag.DagContext.get_current_dag
[function]
[call site]
00110
airflow.utils.task_group.TaskGroup._check_for_group_id_collisions
[function]
[call site]
00111
re.split
[function]
[call site]
00112
.sorted
[function]
[call site]
00113
re.split
[function]
[call site]
00114
.int
[function]
[call site]
00115
re.match
[function]
[call site]
00116
airflow.utils.task_group.TaskGroup.add
[function]
[call site]
00117
.isinstance
[function]
[call site]
00118
weakref.proxy
[function]
[call site]
00119
.hasattr
[function]
[call site]
00120
.isinstance
[function]
[call site]
00121
airflow.utils.task_group.TaskGroup._update_default_args
[function]
[call site]
00122
.set
[function]
[call site]
00123
.set
[function]
[call site]
00124
.set
[function]
[call site]
00125
.set
[function]
[call site]
00126
airflow.models.dag.DAG.validate_schedule_and_params
[function]
[call site]
00127
airflow.models.param.ParamsDict.items
[function]
[call site]
00128
typing.ItemsView
[function]
[call site]
00129
airflow.models.dag.DAG.iter_invalid_owner_links
[function]
[call site]
00130
urllib.parse.urlsplit
[function]
[call site]
00131
.dict
[function]
[call site]
00132
fdp.ConsumeString
[function]
[call site]
00133
fdp.ConsumeIntInRange
[function]
[call site]
00134
airflow.operators.dummy_operator.DummyOperator
[function]
[call site]
00135
fdp.ConsumeString
[function]
[call site]
00136
airflow.operators.python_operator.PythonOperator
[function]
[call site]
00137