feat(processor): get user/project from queue item w/ fallback

This commit is contained in:
psychedelicious 2024-05-23 15:57:30 +10:00
parent a1f7a9cd6f
commit 097619ef51

View File

@ -224,8 +224,8 @@ class DefaultSessionRunner(SessionRunnerBase):
source_node_id=queue_item.session.prepared_source_mapping[invocation.id], source_node_id=queue_item.session.prepared_source_mapping[invocation.id],
error_type=exc_type.__name__, error_type=exc_type.__name__,
error=stacktrace, error=stacktrace,
user_id=None, user_id=getattr(queue_item, 'user_id', None),
project_id=None, project_id=getattr(queue_item, 'project_id', None),
) )
for callback in self._on_node_error_callbacks: for callback in self._on_node_error_callbacks: