Initialize RespanTelemetry

import os
from respan_tracing import RespanTelemetry

os.environ["RESPAN_API_KEY"] = "your-api-key"
os.environ["RESPAN_BASE_URL"] = "https://api.respan.ai/api"

k_tl = RespanTelemetry()

from respan_tracing.decorators import workflow, task

@workflow(name="pipeline")
def pipeline():
    @task(name="step")
    def step():
        return "ok"
    return step()

print(pipeline())