feat: Pass through agent_state and patch bugs [LET-4456] (#4800)
* Pass through agent state * temp * Patch bugs * Add todo for jin
This commit is contained in:
committed by
Caren Thomas
parent
7ca6aba229
commit
678350a6f2
@@ -47,7 +47,7 @@ class TemporalAgent(BaseAgentV2):
|
||||
settings.temporal_endpoint,
|
||||
namespace=settings.temporal_namespace,
|
||||
api_key=settings.temporal_api_key,
|
||||
tls=True, # This should be false for local runs
|
||||
tls=False, # This should be false for local runs
|
||||
)
|
||||
|
||||
workflow_input = WorkflowInputParams(
|
||||
|
||||
@@ -1498,7 +1498,7 @@ async def cancel_agent_run(
|
||||
settings.temporal_endpoint,
|
||||
namespace=settings.temporal_namespace,
|
||||
api_key=settings.temporal_api_key,
|
||||
tls=True,
|
||||
tls=False, # This should be false for local runs
|
||||
)
|
||||
await client.cancel_workflow(run_id)
|
||||
success = await server.job_manager.safe_update_job_status_async(
|
||||
|
||||
@@ -119,7 +119,7 @@ async def retrieve_run(
|
||||
settings.temporal_endpoint,
|
||||
namespace=settings.temporal_namespace,
|
||||
api_key=settings.temporal_api_key,
|
||||
tls=True, # This should be false for local runs
|
||||
tls=False, # This should be false for local runs
|
||||
)
|
||||
handle = client.get_workflow_handle(run_id)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user