Executions

from julep import Julep
import yaml
client = Julep(api_key="YOUR_API_KEY")

# Execute the task (assuming the task is already created)
execution = client.executions.create(
    task_id="task_id",
    input={
        "parameter1": "value1",
        "parameter2": "value2"
    }
)

print(f"Execution ID: {execution.id}")

import time
from julep import Julep

client = Julep(api_key="YOUR_API_KEY")
execution_id = "YOUR_EXECUTION_ID"

while True:
    result = client.executions.get(execution_id)
    print(f"Status: {result.status}")
    print(f"Current output: {result.output}")

    if result.status in ["succeeded", "failed", "cancelled"]:
        if result.status == "succeeded":
            print("Execution succeeded with output:", result.output)
        else:
            print("Execution ended with status:", result.status)
        break

    time.sleep(5)  # Wait for 5 seconds before polling again

from julep import Julep

client = Julep(api_key="YOUR_API_KEY")
execution_id = "YOUR_EXECUTION_ID"

transitions = client.executions.transitions.list(execution_id)
print(transitions.items)

from julep import AsyncClient

client = AsyncClient(api_key="YOUR_API_KEY")
execution_id = "YOUR_EXECUTION_ID"

# Subscribe to the live status stream (async generator)
status_stream = await client.executions.status.stream(execution_id=execution_id)

# Consume events in real-time using async for
async for event in status_stream:
    print("Execution status:", event.status, "updated at", event.updated_at)

from julep import Julep

client = Julep(api_key="YOUR_API_KEY")
execution_id = "YOUR_EXECUTION_ID"

# To cancel an execution
client.executions.change_status(execution_id=execution_id, status="cancelled")
# To resume an execution with specific input
client.executions.change_status(
    execution_id=execution_id,
    status="running",
    input={
        "parameter1": "value1",
        "parameter2": "value2"
    }
)