import asyncio
import dspy

dspy.configure(lm=dspy.LM("openai/gpt-4o-mini", cache=False))

# Create the program and wrap it with streaming functionality
class Hello(dspy.Signature):
    world: List[str] = dspy.OutputField()

predict = dspy.Predict(Hello)
stream_listeners = [
    dspy.streaming.StreamListener(signature_field_name="world"),
]
stream_predict = dspy.streamify(predict, stream_listeners=stream_listeners)

async def use_streaming():
    output = stream_predict(
        question="why did a chicken cross the kitchen?",
        include_final_prediction_in_output_stream=False,
    )
    return_value = None
    async for value in output:
        if isinstance(value, dspy.Prediction):
            return_value = value
        else:
            print(value)
    return return_value

output = asyncio.run(use_streaming())
print(output)

import dspy
from typing import List
    
class Hello(dspy.Signature):
    world: List[str] = dspy.OutputField()

t=Hello.output_fields["world"].annotation
print(f"{t=}")

# Only call issubclass if t is actually a class
import inspect
if inspect.isclass(t):
    issubclass(t, str)
else: print("not a class")