We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 41db5c1 commit 4ddd181Copy full SHA for 4ddd181
dspy/utils/streaming.py
@@ -266,10 +266,9 @@ async def use_streaming():
266
status_streaming_callback = StatusStreamingCallback(status_message_provider)
267
if not any(isinstance(c, StatusStreamingCallback) for c in callbacks):
268
callbacks.append(status_streaming_callback)
269
- settings.configure(callbacks=callbacks)
270
271
async def generator(args, kwargs, stream: MemoryObjectSendStream):
272
- with settings.context(send_stream=stream):
+ with settings.context(send_stream=stream, callbacks=callbacks):
273
prediction = await program(*args, **kwargs)
274
275
await stream.send(prediction)
0 commit comments