We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2f39146 commit f1814e5Copy full SHA for f1814e5
1 file changed
workflow_streams/activities/llm_activity.py
@@ -33,10 +33,7 @@ async def stream_completion(input: LLMInput) -> str:
33
34
No ``force_flush=True``: the 200ms ``batch_interval`` is fast
35
enough for an interactive feel, and the WorkflowStreamClient's
36
- ``__aexit__`` cancels a sleeping flusher cleanly. (The doc example
37
- uses ``force_flush=True`` on the first delta; that path currently
38
- wedges the activity's exit on a cancel-mid-flight bug — fix is
39
- pending in ``temporalio.contrib.workflow_streams``.)
+ ``__aexit__`` cancels a sleeping flusher cleanly.
40
"""
41
stream_client = WorkflowStreamClient.from_within_activity(
42
batch_interval=timedelta(milliseconds=200),
0 commit comments