Allow data store upsearch to work from within a parallel gateway (#1002)

This commit is contained in:
jbirddog 2024-02-08 12:04:48 -05:00 committed by GitHub
parent d1e30f9d91
commit 886f1f5757
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -115,8 +115,13 @@ class ExecutionStrategy:
spiff_task: SpiffTask,
app: flask.app.Flask,
user: Any | None,
process_model_identifier: str,
) -> SpiffTask:
with app.app_context():
tld = current_app.config.get("THREAD_LOCAL_DATA")
if tld:
tld.process_model_identifier = process_model_identifier
g.user = user
spiff_task.run()
return spiff_task
@ -159,6 +164,7 @@ class ExecutionStrategy:
spiff_task,
current_app._get_current_object(),
user,
process_instance_model.process_model_identifier,
)
)
for future in concurrent.futures.as_completed(futures):