@@ -70,6 +70,7 @@ def callback(
70
70
cancel = None ,
71
71
manager = None ,
72
72
cache_args_to_ignore = None ,
73
+ cache_ignore_triggered = True ,
73
74
on_error : Optional [Callable [[Exception ], Any ]] = None ,
74
75
** _kwargs ,
75
76
):
@@ -139,6 +140,9 @@ def callback(
139
140
with keyword arguments (Input/State provided in a dict),
140
141
this should be a list of argument names as strings. Otherwise,
141
142
this should be a list of argument indices as integers.
143
+ :param cache_ignore_triggered:
144
+ Whether to ignore which inputs triggered the callback when creating
145
+ the cache.
142
146
:param interval:
143
147
Time to wait between the long callback update requests.
144
148
:param on_error:
@@ -185,6 +189,8 @@ def callback(
185
189
if cache_args_to_ignore :
186
190
long_spec ["cache_args_to_ignore" ] = cache_args_to_ignore
187
191
192
+ long_spec ["cache_ignore_triggered" ] = cache_ignore_triggered
193
+
188
194
return register_callback (
189
195
callback_list ,
190
196
callback_map ,
@@ -393,12 +399,16 @@ def add_context(*args, **kwargs):
393
399
job_id = flask .request .args .get ("job" )
394
400
old_job = flask .request .args .getlist ("oldJob" )
395
401
402
+ cache_ignore_triggered = long .get ("cache_ignore_triggered" , True )
403
+
396
404
current_key = callback_manager .build_cache_key (
397
405
func ,
398
406
# Inputs provided as dict is kwargs.
399
407
func_args if func_args else func_kwargs ,
400
408
long .get ("cache_args_to_ignore" , []),
401
- callback_ctx .get ("triggered_inputs" , []),
409
+ None
410
+ if cache_ignore_triggered
411
+ else callback_ctx .get ("triggered_inputs" , []),
402
412
)
403
413
404
414
if old_job :
0 commit comments