Module: Hatchet

Defined in:
lib/hatchet-sdk.rb,
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/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

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, Client, ConcurrencyExpression, Config, Context, DedupeViolationError, DefaultFilter, DesiredWorkerLabel, DurableContext, DurableTaskEvictedError, Error, EvictionPolicy, FailedRunError, HealthcheckConfig, NonDeterminismError, NonRetryableError, OrCondition, ParentCondition, RateLimit, ResourceExhaustedError, ScheduleTriggerWorkflowOptions, SleepCondition, TLSConfig, Task, TaskRunError, TaskRunRef, TriggerWorkflowOptions, UserEventCondition, Worker, WorkerContext, Workflow, WorkflowRunListener, WorkflowRunRef

Constant Summary collapse

VERSION = 
"0.3.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.

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 (Array) —

    Conditions to OR together

Returns:



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

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