pyncette.model module

class pyncette.model.Context[source]

Bases: object

Task execution context. This class can have dynamic attributes.

class pyncette.model.ExecutionMode[source]

Bases: enum.Enum

The execution mode for a Pyncette task.

AT_LEAST_ONCE = 0
AT_MOST_ONCE = 1
class pyncette.model.FailureMode[source]

Bases: enum.Enum

What should happen when a task fails.

COMMIT = 2
NONE = 0
UNLOCK = 1
class pyncette.model.FixtureFunc(*args, **kwargs)[source]

Bases: typing.Protocol

class pyncette.model.Heartbeater(*args, **kwargs)[source]

Bases: typing.Protocol

class pyncette.model.MiddlewareFunc(*args, **kwargs)[source]

Bases: typing.Protocol

class pyncette.model.NextFunc(*args, **kwargs)[source]

Bases: typing.Protocol

class pyncette.model.PartitionSelector(*args, **kwargs)[source]

Bases: typing.Protocol

class pyncette.model.PollResponse(result: ResultType, scheduled_at: datetime.datetime, lease: Lease | None)[source]

Bases: object

The result of a task poll

class pyncette.model.QueryResponse(tasks: list[tuple[pyncette.task.Task, Lease]], continuation_token: ContinuationToken | None)[source]

Bases: object

The result of a task query

class pyncette.model.ResultType[source]

Bases: enum.Enum

Status returned by polling the task

LEASE_MISMATCH = 4
LOCKED = 3
MISSING = 0
PENDING = 1
READY = 2
class pyncette.model.TaskFunc(*args, **kwargs)[source]

Bases: typing.Protocol