Skip to content

Commit d5754dd

Browse files
committed
Fix memory leak while preserving parenting
1 parent 97be072 commit d5754dd

File tree

5 files changed

+1510
-741
lines changed

5 files changed

+1510
-741
lines changed

durabletask/internal/helpers.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,8 @@ def new_orchestrator_completed_event() -> pb.HistoryEvent:
2727

2828
def new_execution_started_event(name: str, instance_id: str, encoded_input: Optional[str] = None,
2929
tags: Optional[dict[str, str]] = None,
30-
version: Optional[str] = None) -> pb.HistoryEvent:
30+
version: Optional[str] = None,
31+
parent_trace_context: Optional[pb.TraceContext] = None) -> pb.HistoryEvent:
3132
return pb.HistoryEvent(
3233
eventId=-1,
3334
timestamp=timestamp_pb2.Timestamp(),
@@ -36,7 +37,8 @@ def new_execution_started_event(name: str, instance_id: str, encoded_input: Opti
3637
version=get_string_value(version),
3738
input=get_string_value(encoded_input),
3839
orchestrationInstance=pb.OrchestrationInstance(instanceId=instance_id),
39-
tags=tags))
40+
tags=tags,
41+
parentTraceContext=parent_trace_context))
4042

4143

4244
def new_timer_created_event(timer_id: int, fire_at: datetime) -> pb.HistoryEvent:

0 commit comments

Comments
 (0)