_CheckpointDefinition

Callable wrapper returned by @checkpoint.

Functions

func__init__(self, func, *, retries, checkpoint_type) -> None

Initialize a Kitaru checkpoint wrapper.

paramself

paramfuncCallable[..., Any]

paramretriesint

paramcheckpoint_typestr | None

Returns

None

func_assert_call_allowed(self) -> None

Validate that checkpoint call semantics match Kitaru MVP rules.

paramself

Returns

None

func_assert_submit_allowed(self) -> None

Validate that checkpoint submission is legal in the current context.

paramself

Returns

None

func__call__(self, *args, *, id=None, after=None, **kwargs) -> Any

Call the checkpoint with context guardrails.

paramself

paramargsAny

= ()

paramidstr | None

= None

paramafterAny | Sequence[Any] | None

= None

paramkwargsAny

= {}

Returns

typing.Any

funcsubmit(self, *args, *, id=None, after=None, **kwargs) -> Any

Submit the checkpoint concurrently inside a running flow.

paramself

paramargsAny

= ()

paramidstr | None

= None

paramafterAny | Sequence[Any] | None

= None

paramkwargsAny

= {}

Returns

typing.Any

funcmap(self, *args, *, after=None, **kwargs) -> Any

Map checkpoint invocations inside a running flow.

paramself

paramargsAny

= ()

paramafterAny | Sequence[Any] | None

= None

paramkwargsAny

= {}

Returns

typing.Any

funcproduct(self, *args, *, after=None, **kwargs) -> Any

Map checkpoint invocations as a cartesian product in a running flow.

paramself

paramargsAny

= ()

paramafterAny | Sequence[Any] | None

= None

paramkwargsAny

= {}

Returns

typing.Any

_CheckpointDefinition

Functions

On this page