File tree Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Original file line number Diff line number Diff line change 1
1
from functools import wraps
2
2
from agents .run import set_default_agent_runner
3
+ from azure .durable_functions .models .DurableOrchestrationContext import DurableOrchestrationContext
3
4
from durable_openai_runner import DurableOpenAIRunner
4
5
from yield_exception import YieldException
5
6
from durable_ai_agent_context import DurableAIAgentContext
8
9
9
10
def durable_openai_agent_orchestrator (func ):
10
11
@wraps (func )
11
- def wrapper (context ):
12
+ def wrapper (durable_orchestration_context : DurableOrchestrationContext ):
12
13
event_loop .ensure_event_loop ()
13
- context = DurableAIAgentContext (context )
14
- durable_openai_runner = DurableOpenAIRunner (context = context )
14
+ durable_ai_agent_context = DurableAIAgentContext (durable_orchestration_context )
15
+ durable_openai_runner = DurableOpenAIRunner (context = durable_ai_agent_context )
15
16
set_default_agent_runner (durable_openai_runner )
16
17
17
18
try :
18
- result = func (context )
19
+ result = func (durable_ai_agent_context )
19
20
return result
20
21
except YieldException as e :
21
- yield from context .yield_and_clear_tasks ()
22
+ yield from durable_ai_agent_context .yield_and_clear_tasks ()
22
23
yield e .task
23
24
finally :
24
- yield from context .yield_and_clear_tasks ()
25
-
25
+ yield from durable_ai_agent_context .yield_and_clear_tasks ()
26
+
26
27
return wrapper
You can’t perform that action at this time.
0 commit comments