Module: Hatchet

Defined in:
lib/hatchet-sdk.rb,
lib/hatchet/task.rb,
lib/hatchet/config.rb,
lib/hatchet/labels.rb,
lib/hatchet/clients.rb,
lib/hatchet/context.rb,
lib/hatchet/version.rb,
lib/hatchet/workflow.rb,
lib/hatchet/conditions.rb,
lib/hatchet/connection.rb,
lib/hatchet/exceptions.rb,
lib/hatchet/rate_limit.rb,
lib/hatchet/worker_obj.rb,
lib/hatchet/concurrency.rb,
lib/hatchet/idempotency.rb,
lib/hatchet/context_vars.rb,
lib/hatchet/features/cel.rb,
lib/hatchet/workflow_run.rb,
lib/hatchet/features/cron.rb,
lib/hatchet/features/logs.rb,
lib/hatchet/features/runs.rb,
lib/hatchet/worker/runner.rb,
lib/hatchet/default_filter.rb,
lib/hatchet/engine_version.rb,
lib/hatchet/durable_context.rb,
lib/hatchet/eviction_policy.rb,
lib/hatchet/features/events.rb,
lib/hatchet/features/tenant.rb,
lib/hatchet/trigger_options.rb,
lib/hatchet/features/filters.rb,
lib/hatchet/features/metrics.rb,
lib/hatchet/features/workers.rb,
lib/hatchet/clients/grpc/admin.rb,
lib/hatchet/features/scheduled.rb,
lib/hatchet/features/workflows.rb,
lib/hatchet/condition_converter.rb,
lib/hatchet/worker/health_check.rb,
lib/hatchet/features/rate_limits.rb,
lib/hatchet/worker/action_listener.rb,
lib/hatchet/clients/grpc/dispatcher.rb,
lib/hatchet/clients/grpc/event_client.rb,
lib/hatchet/worker/workflow_run_listener.rb,
lib/hatchet/worker/durable_event_listener.rb,
lib/hatchet/worker/durable_eviction/cache.rb,
lib/hatchet/worker/durable_eviction/manager.rb,
sig/hatchet-sdk.rbs,
sig/hatchet/task.rbs,
sig/hatchet/config.rbs,
sig/hatchet/labels.rbs,
sig/hatchet/clients.rbs,
sig/hatchet/context.rbs,
sig/hatchet/version.rbs,
sig/hatchet/workflow.rbs,
sig/hatchet/conditions.rbs,
sig/hatchet/connection.rbs,
sig/hatchet/exceptions.rbs,
sig/hatchet/rate_limit.rbs,
sig/hatchet/worker_obj.rbs,
sig/hatchet/concurrency.rbs,
sig/hatchet/idempotency.rbs,
sig/hatchet/context_vars.rbs,
sig/hatchet/features/cel.rbs,
sig/hatchet/workflow_run.rbs,
sig/hatchet/features/cron.rbs,
sig/hatchet/features/logs.rbs,
sig/hatchet/features/runs.rbs,
sig/hatchet/worker/runner.rbs,
sig/hatchet/default_filter.rbs,
sig/hatchet/engine_version.rbs,
sig/hatchet/durable_context.rbs,
sig/hatchet/eviction_policy.rbs,
sig/hatchet/features/events.rbs,
sig/hatchet/features/tenant.rbs,
sig/hatchet/trigger_options.rbs,
sig/hatchet/features/filters.rbs,
sig/hatchet/features/metrics.rbs,
sig/hatchet/features/workers.rbs,
sig/hatchet/clients/grpc/admin.rbs,
sig/hatchet/features/scheduled.rbs,
sig/hatchet/features/workflows.rbs,
sig/hatchet/condition_converter.rbs,
sig/hatchet/worker/health_check.rbs,
sig/hatchet/features/rate_limits.rbs,
sig/hatchet/worker/action_listener.rbs,
sig/hatchet/clients/grpc/dispatcher.rbs,
sig/hatchet/clients/grpc/event_client.rbs,
sig/hatchet/worker/workflow_run_listener.rbs,
sig/hatchet/worker/durable_event_listener.rbs,
sig/hatchet/worker/durable_eviction/cache.rbs,
sig/hatchet/worker/durable_eviction/manager.rbs

Overview

Hatchet clients module This module provides access to different client types (REST, gRPC, etc.)

Defined Under Namespace

Modules: Clients, ConcurrencyLimitStrategy, ConditionConverter, Connection, ContextVars, EngineVersion, Features, MinEngineVersion, RateLimitDuration, StickyStrategy, WorkerLabelComparator, WorkerRuntime Classes: AdminClient, BulkTriggerIdempotencyCollisionError, Client, ConcurrencyExpression, Config, Context, DedupeViolationError, DefaultFilter, DesiredWorkerLabel, DurableContext, DurableTaskEvictedError, Error, EvictionPolicy, FailedRunError, HealthcheckConfig, IdempotencyCollisionError, NonDeterminismError, NonRetryableError, OpenTelemetryConfig, OrCondition, ParentCondition, RateLimit, ResourceExhaustedError, ScheduleTriggerWorkflowOptions, SleepCondition, TLSConfig, TTLBasedIdempotencyConfig, Task, TaskRunError, TaskRunRef, TriggerWorkflowOptions, UserEventCondition, Worker, WorkerContext, Workflow, WorkflowRunListener, WorkflowRunRef

Constant Summary collapse

VERSION =

Returns:

  • (String) 
"0.4.0"
DEFAULT_DURABLE_TASK_EVICTION_POLICY =

Shared sensible defaults.

NOTE: When changing these values, update the :param eviction_policy: docstrings in :meth:Workflow#durable_task and :meth:Client#durable_task to match.

Returns:

EvictionPolicy.new(
  ttl: 15 * 60, # 15 minutes
  allow_capacity_eviction: true,
  priority: 0,
)

Class Method Summary collapse

Class Method Details

.or_(*conditions) ⇒ OrCondition

Create an OR condition group

Parameters:

  • conditions (Object)

Returns:



107
108
109
 
# File 'lib/hatchet/conditions.rb', line 107

def self.or_(*conditions)
  OrCondition.new(*conditions)
end