Index A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W A ack() (flowli.domain.ports.Queue method) acquire() (flowli.domain.ports.Ownership method) Actor (class in flowli.domain) actor (flowli.api.Principal attribute) (flowli.domain.Provenance attribute) actor_claim (flowli.api.OIDCConfig attribute) add() (flowli.evidence.AttemptBuffer method) adopted (flowli.runtime.Held attribute) advance() (flowli.adapters.memory.ManualClock method) all_waits() (flowli.domain.ports.Channel method) allows() (flowli.api.Principal method) allows_retry() (flowli.domain.RetryPolicy method) announce() (flowli.domain.Entry class method) (flowli.domain.ports.ControlLog method) (flowli.runtime.Context method) announcements() (flowli.adapters.cairndb_projection.WorkflowProjection method) ApiConfig (class in flowli.api) append() (flowli.domain.ports.Journal method) append_log() (flowli.domain.ports.Evidence method) (flowli.evidence.NullEvidence method) apply() (flowli.domain.MemoTable method) (flowli.runtime.ControlView method) Archive (class in flowli.domain.ports) archive (flowli.domain.ports.Ports attribute) archive() (flowli.runtime.Engine method) archived (flowli.runtime.KnownExecution attribute) (flowli.runtime.RetentionReport attribute) args (flowli.domain.Execution attribute) args_digest (flowli.domain.Frame attribute) at (flowli.domain.Provenance attribute) (flowli.patterns.Decision attribute) attach() (flowli.domain.ports.Queue method) Attempt (class in flowli.domain) attempt (flowli.domain.ports.EvidenceRef attribute) (flowli.domain.Provenance attribute) (flowli.runtime.Context property) AttemptBuffer (class in flowli.evidence) audience (flowli.api.OIDCConfig attribute) authenticate() (flowli.api.CachingAuthenticator method) (flowli.api.OIDCAuthenticator method) (flowli.api.StaticAuthenticator method) B backoff (flowli.domain.RetryPolicy attribute) backoff_factor (flowli.domain.RetryPolicy attribute) bound() (in module flowli.log) broadcast() (flowli.runtime.Engine method) build() (flowli.domain.MemoTable class method) by (flowli.patterns.Decision attribute) C CachingAuthenticator (class in flowli.api) CairnBackend (class in flowli.adapters.cairndb) cancel() (flowli.runtime.Engine method) cancel_requested (flowli.runtime.Held property) cancel_requested() (flowli.runtime.Context method) Cancelled CANCELLED (flowli.domain.ExecutionStatus attribute) cancelled (flowli.domain.MemoTable attribute) canonical_json() (in module flowli.codec) capabilities (flowli.api.Principal attribute) capture() (in module flowli.evidence) Catalog (class in flowli.api) Channel (class in flowli.domain.ports) CHANNEL (flowli.domain.Condition attribute) channel (flowli.domain.Message attribute) (flowli.domain.ports.Ports attribute) channel() (flowli.domain.Condition static method) check_channel() (in module flowli.domain.names) check_digest() (flowli.domain.MemoTable method) check_frame_name() (in module flowli.domain.names) check_queue() (in module flowli.domain.names) CHILD (flowli.domain.Condition attribute) (flowli.domain.FrameKind attribute) child() (flowli.domain.Condition static method) (flowli.runtime.Context method) child_channel (flowli.domain.FrameRef property) child_eid (flowli.domain.FrameRef property) ChildFailed children() (flowli.adapters.cairndb_projection.WorkflowProjection method) claim() (flowli.domain.ports.Dispatch method) claim_start() (flowli.domain.ports.Dispatch method) claimed (flowli.domain.ports.QueueDepth attribute) (flowli.runtime.Held attribute) ClaimedTask (class in flowli.domain.ports) cleaned (flowli.runtime.RetentionReport attribute) clear_wait() (flowli.domain.ports.Channel method) client_claim (flowli.api.OIDCConfig attribute) clock (flowli.adapters.memory.MemoryBackend attribute) close() (flowli.adapters.cairndb.CairnBackend method) Code (class in flowli.domain) code (flowli.domain.Provenance attribute) code_ref (flowli.domain.Code attribute) (flowli.runtime.EngineConfig attribute) collecting() (flowli.evidence.EvidenceWriter method) Completed (class in flowli.domain) COMPLETED (flowli.domain.ExecutionStatus attribute) Condition (class in flowli.domain) configure() (flowli.adapters.cairndb.CairnBackend class method) configure_logging() (in module flowli.log) conflict_delay (flowli.runtime.ConsumerConfig attribute) connect() (flowli.adapters.cairndb_projection.WorkflowProjection method) consumed (flowli.domain.MemoTable attribute) Consumer (class in flowli.runtime) ConsumerConfig (class in flowli.runtime) ConsumerReport (class in flowli.runtime) Context (class in flowli.runtime) control (flowli.domain.ports.Ports attribute) ControlLog (class in flowli.domain.ports) ControlSource (class in flowli.runtime) ControlView (class in flowli.runtime) correlation (flowli.domain.Message attribute) counts_by_status() (flowli.adapters.cairndb_projection.WorkflowProjection method) create() (flowli.domain.ports.ExecutionStore method) create_app() (in module flowli.api) create_execution() (flowli.runtime.Engine method) created_by (flowli.domain.Execution attribute) D data (flowli.patterns.Decision attribute) deadline (flowli.runtime.Wait attribute) deadline_at (flowli.domain.ports.Lease property) (flowli.domain.ports.LeaseInfo attribute) deadlines (flowli.domain.MemoTable attribute) decide() (flowli.patterns.Reviews method) Decision (class in flowli.patterns) deduplicated (flowli.runtime.engine.StartResult attribute) default_limit (flowli.api.ApiConfig attribute) default_queue (flowli.api.ApiConfig attribute) (flowli.runtime.EngineConfig attribute) delay_after() (flowli.domain.RetryPolicy method) DELEGATE (flowli.domain.TaskKind attribute) delegate() (in module flowli.patterns) DelegateTask (class in flowli.domain) delete() (flowli.domain.ports.ExecutionStore method) (flowli.domain.ports.Journal method) (flowli.domain.ports.Ownership method) delete_channel() (flowli.domain.ports.Channel method) delete_for() (flowli.domain.ports.Evidence method) (flowli.evidence.NullEvidence method) deliver() (flowli.runtime.Engine method) delivered (flowli.runtime.ConsumerReport attribute) depth() (flowli.domain.ports.Queue method) dequeue() (flowli.domain.ports.Queue method) digest() (in module flowli.codec) digest_text() (in module flowli.domain.names) digests (flowli.domain.MemoTable attribute) Dispatch (class in flowli.domain.ports) dispatch (flowli.domain.ports.Ports attribute) dispatch_key (flowli.domain.Execution attribute) drain() (flowli.evidence.AttemptBuffer method) dropped (flowli.evidence.AttemptBuffer attribute) due() (flowli.domain.ports.Timers method) due_at (flowli.domain.Timer attribute) DuplicateFrameError E eid (flowli.domain.DelegateTask attribute) (flowli.domain.Execution attribute) (flowli.domain.FrameRef attribute) (flowli.domain.ports.EvidenceRef attribute) (flowli.runtime.engine.StartResult attribute) Eid (in module flowli.domain.names) Engine (class in flowli.runtime) EngineConfig (class in flowli.runtime) enqueue() (flowli.domain.ports.Queue method) (flowli.runtime.Context method) (flowli.runtime.Engine method) enqueue_resume() (flowli.runtime.Engine method) enqueued_by (flowli.domain.Task attribute) ensure() (flowli.domain.ports.Queue method) entries() (flowli.api.Catalog method) (flowli.runtime.Registry method) Entry (class in flowli.domain) entry() (flowli.api.Catalog method) EntryType (class in flowli.domain) epoch (flowli.domain.ports.Lease property) (flowli.domain.ports.LeaseInfo attribute) (flowli.domain.Site attribute) error (flowli.runtime.Raised attribute) error_type (flowli.domain.Failed attribute) Evidence (class in flowli.domain.ports) evidence (flowli.domain.ports.Ports attribute) EvidenceItem (class in flowli.domain.ports) EvidenceRef (class in flowli.domain.ports) EvidenceWriter (class in flowli.evidence) exec_ttl (flowli.runtime.EngineConfig attribute) Execution (class in flowli.domain) execution() (flowli.adapters.cairndb_projection.WorkflowProjection method) (flowli.runtime.Engine method) EXECUTION_ARCHIVED (flowli.domain.EntryType attribute) EXECUTION_CANCELLED (flowli.domain.EntryType attribute) execution_cancelled() (flowli.domain.Entry class method) execution_channel() (in module flowli.domain) EXECUTION_COMPLETED (flowli.domain.EntryType attribute) execution_completed() (flowli.domain.Entry class method) EXECUTION_CREATED (flowli.domain.EntryType attribute) EXECUTION_FAILED (flowli.domain.EntryType attribute) execution_failed() (flowli.domain.Entry class method) EXECUTION_MIGRATED (flowli.domain.EntryType attribute) execution_migrated() (flowli.domain.Entry class method) EXECUTION_RESUMED (flowli.domain.EntryType attribute) execution_resumed() (flowli.domain.Entry class method) EXECUTION_STARTED (flowli.domain.EntryType attribute) execution_started() (flowli.domain.Entry class method) EXECUTION_SUSPENDED (flowli.domain.EntryType attribute) execution_suspended() (flowli.domain.Entry class method) executions (flowli.domain.ports.Ports attribute) (flowli.runtime.ControlView attribute) executions() (flowli.adapters.cairndb_projection.WorkflowProjection method) ExecutionStatus (class in flowli.domain) ExecutionStore (class in flowli.domain.ports) F Failed (class in flowli.domain) FAILED (flowli.domain.ExecutionStatus attribute) failures (flowli.domain.MemoTable attribute) fan_out() (in module flowli.patterns) fid (flowli.domain.DelegateTask attribute) (flowli.domain.Entry attribute) (flowli.domain.FrameRef attribute) (flowli.domain.ports.EvidenceRef attribute) (flowli.runtime.Context property) (flowli.runtime.Wait attribute) final() (flowli.evidence.AttemptBuffer method) flowli.codec module flowli.domain.errors module flowli.domain.names module flowli.domain.ports module flowli.evidence module flowli.log module FlowliError fn (flowli.runtime.WorkflowRef attribute) fold() (flowli.runtime.Retention method) Frame (class in flowli.domain) frame (flowli.domain.Attempt attribute) FRAME_COMPLETED (flowli.domain.EntryType attribute) frame_completed() (flowli.domain.Entry class method) FRAME_FAILED (flowli.domain.EntryType attribute) frame_failed() (flowli.domain.Entry class method) FRAME_FULFILLED (flowli.domain.EntryType attribute) frame_fulfilled() (flowli.domain.Entry class method) frame_kind (flowli.domain.Code attribute) frame_name (flowli.domain.Code attribute) FRAME_STARTED (flowli.domain.EntryType attribute) frame_started() (flowli.domain.Entry class method) FRAME_SUSPENDED (flowli.domain.EntryType attribute) frame_suspended() (flowli.domain.Entry class method) FrameKind (class in flowli.domain) FrameRef (class in flowli.domain) from_exception() (flowli.domain.Failed class method) from_task_payload() (flowli.domain.DelegateTask class method) fulfilled (flowli.domain.MemoTable attribute) G gather() (flowli.runtime.Context method) get() (flowli.domain.ports.Evidence method) (flowli.evidence.NullEvidence method) (flowli.runtime.Registry method) get_logger() (in module flowli.log) grace (flowli.runtime.ConsumerConfig attribute) groups_claim (flowli.api.OIDCConfig attribute) H handle (flowli.runtime.Held property) Handler (class in flowli.runtime) Held (class in flowli.runtime) holder (flowli.domain.ports.LeaseInfo attribute) (flowli.runtime.ConsumerConfig attribute) host (flowli.domain.Site attribute) human() (flowli.domain.Actor class method) I id (flowli.domain.Actor attribute) id_for() (flowli.domain.Task static method) inspect() (flowli.domain.ports.Ownership method) instance (flowli.domain.Site attribute) interrupt() (flowli.runtime.Handler method) InvalidName is_due() (flowli.domain.Timer method) is_expired() (flowli.domain.ports.LeaseInfo method) is_terminal (flowli.domain.Entry property) (flowli.domain.ExecutionStatus property) (flowli.domain.MemoTable property) issuer (flowli.api.OIDCConfig attribute) item (flowli.domain.Sequenced attribute) J Journal (class in flowli.domain.ports) journal (flowli.domain.ports.Ports attribute) journal() (flowli.runtime.Engine method) jwks_url (flowli.api.OIDCConfig attribute) K key (flowli.domain.ports.ClaimedTask attribute) (flowli.domain.Task attribute) kind (flowli.domain.Actor attribute) (flowli.domain.Frame attribute) (flowli.domain.Task attribute) KnownExecution (class in flowli.runtime) L last_at (flowli.runtime.KnownExecution attribute) last_consumed() (flowli.domain.MemoTable method) last_type (flowli.runtime.KnownExecution attribute) Lease (class in flowli.domain.ports) lease (flowli.domain.ports.ClaimedTask attribute) (flowli.runtime.Held property) LeaseInfo (class in flowli.domain.ports) LeaseLost leeway (flowli.api.OIDCConfig attribute) limit (flowli.evidence.AttemptBuffer attribute) list() (flowli.domain.ports.Evidence method) (flowli.evidence.NullEvidence method) local() (flowli.domain.Site class method) M machine_actor_kind (flowli.api.OIDCConfig attribute) ManualClock (class in flowli.adapters.memory) max_attempts (flowli.domain.RetryPolicy attribute) max_backoff (flowli.domain.RetryPolicy attribute) max_limit (flowli.api.ApiConfig attribute) max_task_ttl (flowli.api.ApiConfig attribute) max_wait_seconds (flowli.api.ApiConfig attribute) media_type (flowli.domain.ports.EvidenceItem attribute) memo() (flowli.runtime.Engine method) MemoryBackend (class in flowli.adapters.memory) memos (flowli.domain.MemoTable attribute) MemoTable (class in flowli.domain) Message (class in flowli.domain) message (flowli.domain.Failed attribute) migrate() (flowli.runtime.Engine method) module flowli.codec flowli.domain.errors flowli.domain.names flowli.domain.ports flowli.evidence flowli.log N nack() (flowli.domain.ports.Queue method) nack_delay (flowli.api.ApiConfig attribute) (flowli.runtime.ConsumerConfig attribute) (flowli.runtime.EngineConfig attribute) NAME (flowli.adapters.cairndb_projection.WorkflowProjection attribute) name (flowli.domain.Frame attribute) (flowli.domain.ports.EvidenceItem attribute) (flowli.runtime.WorkflowRef attribute) new_eid() (in module flowli.domain.names) next_attempt() (flowli.domain.MemoTable method) NondeterminismError NonRetryableError not_before (flowli.domain.Task attribute) notify_parent() (flowli.runtime.Engine method) now() (flowli.domain.Provenance class method) (flowli.runtime.Context method) NullEvidence (class in flowli.evidence) number (flowli.domain.Attempt attribute) O of() (flowli.runtime.Registry method) OIDCAuthenticator (class in flowli.api) OIDCConfig (class in flowli.api) on (flowli.runtime.Wait attribute) on_behalf_of (flowli.domain.Actor attribute) on_tick() (in module flowli.patterns) OPERATOR (flowli.domain.Condition attribute) operator() (flowli.domain.Condition static method) Ownership (class in flowli.domain.ports) ownership (flowli.domain.ports.Ports attribute) P parent (flowli.domain.Execution attribute) parse() (flowli.domain.Condition static method) parse_eid() (in module flowli.domain.names) path (flowli.adapters.cairndb_projection.WorkflowProjection property) payload (flowli.domain.DelegateTask attribute) (flowli.domain.Entry attribute) (flowli.domain.Message attribute) (flowli.domain.Task attribute) peek() (flowli.domain.ports.Queue method) PENDING (flowli.domain.ExecutionStatus attribute) pending (flowli.evidence.AttemptBuffer attribute) pending() (flowli.domain.ports.Queue method) pending_reviews() (flowli.adapters.cairndb_projection.WorkflowProjection method) pid (flowli.domain.Site attribute) poll() (flowli.runtime.Handler method) poll_interval (flowli.api.ApiConfig attribute) (flowli.runtime.ConsumerConfig attribute) (flowli.runtime.EngineConfig attribute) Ports (class in flowli.domain.ports) ports (flowli.adapters.cairndb.CairnBackend property) (flowli.adapters.memory.MemoryBackend property) (flowli.runtime.Consumer property) (flowli.runtime.Worker property) prepare() (flowli.runtime.Handler method) Principal (class in flowli.api) principals (flowli.api.StaticAuthenticator attribute) projection() (flowli.adapters.cairndb.CairnBackend method) Provenance (class in flowli.domain) provenance (flowli.domain.Attempt attribute) (flowli.domain.Entry attribute) provenance() (flowli.runtime.Engine method) put() (flowli.domain.ports.Evidence method) (flowli.evidence.NullEvidence method) Q Queue (class in flowli.domain.ports) queue (flowli.domain.Execution attribute) (flowli.domain.ports.Ports attribute) (flowli.domain.Task attribute) (flowli.runtime.Held property) (flowli.runtime.KnownExecution attribute) QueueDepth (class in flowli.domain.ports) queues (flowli.api.ApiConfig attribute) (flowli.runtime.ConsumerConfig attribute) R Raised (class in flowli.runtime) random() (flowli.runtime.Context method) read() (flowli.domain.ports.Archive method) (flowli.domain.ports.Channel method) (flowli.domain.ports.ControlLog method) (flowli.domain.ports.ExecutionStore method) (flowli.domain.ports.Journal method) read_log() (flowli.domain.ports.Evidence method) (flowli.evidence.NullEvidence method) ready (flowli.adapters.cairndb_projection.WorkflowProjection property) reason (flowli.domain.Task attribute) reattach() (flowli.runtime.Handler method) RECEIVE (flowli.domain.FrameKind attribute) receive() (flowli.runtime.Context method) recover() (flowli.runtime.Consumer method) recovered (flowli.runtime.ConsumerReport attribute) (flowli.runtime.SweepReport attribute) ref (flowli.domain.Frame attribute) (flowli.domain.ports.EvidenceItem attribute) (flowli.evidence.AttemptBuffer attribute) refresh() (flowli.adapters.cairndb_projection.WorkflowProjection method) refresh_after_write (flowli.api.ApiConfig attribute) refresh_state() (flowli.domain.ports.Lease method) Refused refused (flowli.runtime.ConsumerReport attribute) region (flowli.domain.Site attribute) register() (flowli.runtime.Registry method) register_wait() (flowli.domain.ports.Channel method) Registry (class in flowli.runtime) release() (flowli.domain.ports.Lease method) (flowli.runtime.Handler method) released (flowli.domain.ports.LeaseInfo attribute) remove() (flowli.domain.ports.Timers method) remove_for() (flowli.domain.ports.Timers method) renew() (flowli.domain.ports.Lease method) repaired (flowli.runtime.SweepReport attribute) replace() (flowli.domain.ports.ExecutionStore method) reply_channel (flowli.domain.DelegateTask attribute) reply_channel() (flowli.domain.FrameRef method) reply_fid (flowli.domain.DelegateTask attribute) request_cancel() (flowli.domain.ports.Ownership method) (flowli.domain.ports.Queue method) require() (flowli.api.Principal method) restarted (flowli.runtime.SweepReport attribute) RESUME (flowli.domain.TaskKind attribute) Retention (class in flowli.runtime) retention() (flowli.runtime.Engine method) RetentionReport (class in flowli.runtime) retry (flowli.domain.Frame attribute) retry_at (flowli.domain.MemoTable attribute) retryable (flowli.domain.Failed attribute) RetryPolicy (class in flowli.domain) Returned (class in flowli.runtime) review() (flowli.adapters.cairndb_projection.WorkflowProjection method) (in module flowli.patterns) Reviews (class in flowli.patterns) reviews (flowli.runtime.Engine property) roles (flowli.api.OIDCConfig attribute) ROOT (flowli.domain.FrameKind attribute) run() (flowli.runtime.Context method) run_detached_step() (flowli.runtime.Worker method) run_execution() (flowli.runtime.Worker method) run_forever() (flowli.runtime.Consumer method) (flowli.runtime.Retention method) (flowli.runtime.Sweeper method) (flowli.runtime.Worker method) run_once() (flowli.runtime.Consumer method) (flowli.runtime.Retention method) (flowli.runtime.Sweeper method) (flowli.runtime.Worker method) RUN_STEP (flowli.domain.TaskKind attribute) RUNNING (flowli.domain.ExecutionStatus attribute) S saga() (in module flowli.patterns) schedule() (flowli.domain.Actor class method) (flowli.domain.ports.Timers method) scope_claim (flowli.api.OIDCConfig attribute) scoped() (flowli.domain.ports.Channel method) send() (flowli.domain.ports.Channel method) (flowli.runtime.Context method) sent_by (flowli.domain.Message attribute) seq (flowli.domain.Message attribute) (flowli.domain.Sequenced attribute) Sequenced (class in flowli.domain) set() (flowli.adapters.memory.ManualClock method) signal() (flowli.runtime.Engine method) Site (class in flowli.domain) site (flowli.domain.Provenance attribute) size (flowli.domain.ports.EvidenceItem attribute) SLEEP (flowli.domain.FrameKind attribute) sleep() (flowli.runtime.Context method) sleep_until() (flowli.runtime.Context method) snapshot() (flowli.adapters.cairndb_projection.WorkflowProjection method) (flowli.runtime.ControlSource method) (flowli.runtime.ControlView method) START (flowli.domain.TaskKind attribute) start() (flowli.adapters.cairndb_projection.WorkflowProjection method) (flowli.runtime.Engine method) (flowli.runtime.Handler method) start_child() (flowli.runtime.Engine method) start_result() (flowli.runtime.Engine method) StartResult (class in flowli.runtime.engine) state (flowli.domain.ports.Lease property) (flowli.domain.ports.LeaseInfo attribute) (flowli.runtime.Held property) StaticAuthenticator (class in flowli.api) status (flowli.runtime.KnownExecution attribute) status() (flowli.runtime.Engine method) STEP (flowli.domain.FrameKind attribute) step() (flowli.runtime.Context method) step_channel (flowli.domain.FrameRef property) StepFailed stop() (flowli.adapters.cairndb_projection.WorkflowProjection method) structure() (in module flowli.codec) Suspended (class in flowli.runtime) SUSPENDED (flowli.domain.ExecutionStatus attribute) suspended (flowli.domain.MemoTable attribute) Sweeper (class in flowli.runtime) sweeper() (flowli.runtime.Engine method) SweepReport (class in flowli.runtime) system() (flowli.domain.Actor class method) T tail (flowli.domain.MemoTable attribute) (flowli.evidence.AttemptBuffer attribute) tail() (flowli.domain.ports.Journal method) take() (flowli.domain.ports.Queue method) target (flowli.domain.Task attribute) (flowli.domain.Timer attribute) Task (class in flowli.domain) task (flowli.domain.ports.ClaimedTask attribute) (flowli.runtime.Held attribute) TASK_ENQUEUED (flowli.domain.EntryType attribute) task_enqueued() (flowli.domain.Entry class method) task_id (flowli.domain.Task property) (flowli.runtime.Held property) task_ttl (flowli.api.ApiConfig attribute) (flowli.runtime.EngineConfig attribute) TaskKind (class in flowli.domain) tasks() (flowli.adapters.cairndb_projection.WorkflowProjection method) terminal (flowli.domain.MemoTable attribute) terminal_before() (flowli.adapters.cairndb_projection.WorkflowProjection method) (flowli.runtime.ControlSource method) (flowli.runtime.ControlView method) terminate() (flowli.runtime.Handler method) terminated (flowli.runtime.ConsumerReport attribute) Timer (class in flowli.domain) TIMER (flowli.domain.Condition attribute) timer() (flowli.domain.Condition static method) timer_id (flowli.domain.Timer property) Timers (class in flowli.domain.ports) timers (flowli.domain.ports.Ports attribute) timers_fired (flowli.runtime.SweepReport attribute) title (flowli.api.ApiConfig attribute) total (flowli.domain.ports.QueueDepth attribute) (flowli.runtime.SweepReport property) ttl (flowli.runtime.ConsumerConfig attribute) type (flowli.domain.Entry attribute) U UnknownExecution unstructure() (in module flowli.codec) update_state() (flowli.domain.ports.Lease method) uuid() (flowli.runtime.Context method) V validate() (flowli.api.Catalog method) value (flowli.domain.Completed attribute) (flowli.runtime.Returned attribute) verdict (flowli.patterns.Decision attribute) version (flowli.domain.Code attribute) (flowli.domain.Execution attribute) (flowli.runtime.WorkflowRef attribute) visible (flowli.domain.ports.QueueDepth attribute) visible_at() (flowli.domain.Task method) W Wait (class in flowli.runtime) wait_for() (flowli.adapters.cairndb_projection.WorkflowProjection method) wait_ms (flowli.api.ApiConfig attribute) waiters() (flowli.domain.ports.Channel method) waiting_fid (flowli.domain.DelegateTask property) waits (flowli.runtime.Suspended attribute) waits_cleared (flowli.runtime.SweepReport attribute) with_epoch() (flowli.domain.Site method) withdraw() (flowli.runtime.Context method) Worker (class in flowli.runtime) worker() (flowli.domain.Actor class method) (flowli.runtime.Engine method) worker_id (flowli.domain.Site attribute) workflow (flowli.domain.Code attribute) (flowli.domain.Execution attribute) workflow() (flowli.runtime.Engine method) (flowli.runtime.Registry method) workflow_ref() (flowli.runtime.Engine method) WorkflowNotRegistered WorkflowProjection (class in flowli.adapters.cairndb_projection) WorkflowRef (class in flowli.runtime) write() (flowli.domain.ports.Archive method) write_handle() (flowli.runtime.Held method) written (flowli.evidence.AttemptBuffer attribute)