sdkcontext

var (
	// WorkloadContextKey stores the current workload
	//
	// workload := ctx.Value(sdkcontext.WorkloadContextKey).(api.ExecuteTaskWorkload)
	WorkloadContextKey  = workoadContextKey{}
	RuntimeTIContextKey = runtimeTIContextKey{}
	ApiClientContextKey = apiClientContextKey{}
	WorkerContextKey    = workerContextKey{}

	// RuntimeContextKey stores the public, task-facing runtime context
	// (task instance identifiers and the Dag run's scheduling timestamps).
	// The coordinator-mode runtime populates it from StartupDetails; the
	// bundle runtime reads it to inject an sdk.TIRunContext parameter into
	// task functions rather than exposing this key directly. Its value type
	// is sdk.TIRunContext (built over a placeholder base context; the bundle
	// runtime rebuilds it around the live task context at injection time),
	// but this package does not import sdk to avoid an import cycle.
	RuntimeContextKey = runtimeContextKey{}

	// SdkClientContextKey, when present, holds an sdk.Client implementation
	// that should be injected into task functions instead of constructing a
	// default HTTP-backed client. The coordinator-mode runtime uses this to
	// route task SDK calls (GetVariable, GetConnection, ...) over the
	// supervisor comm socket rather than to the Execution API.
	SdkClientContextKey = sdkClientContextKey{}
)