temporal-ruby/examples/bin/worker at eb1024b9d3c9dc87eb9d6e62745196a0c9f59879 · coinbase/temporal-ruby · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
#!/usr/bin/env ruby
require_relative '../init'
require_relative '../lib/crypt_payload_codec'

require 'temporal/worker'

Dir[File.expand_path('../workflows/*.rb', __dir__)].each { |f| require f }
Dir[File.expand_path('../activities/*.rb', __dir__)].each { |f| require f }
Dir[File.expand_path('../middleware/*.rb', __dir__)].each { |f| require f }

if !ENV['USE_ENCRYPTION'].nil?
  Temporal.configure do |config|
    config.task_queue = 'crypt'
    config.payload_codec = Temporal::Connection::Converter::Codec::Chain.new(
      payload_codecs: [
        Temporal::CryptPayloadCodec.new
      ]
    )
  end
end

if !ENV['USE_ERROR_SERIALIZATION_V2'].nil?
  Temporal.configure do |config|
    config.task_queue = 'error_serialization_v2'
    config.use_error_serialization_v2 = true
  end
end

Temporal.configure do |config|
  config.add_header_propagator(SamplePropagator)
end

worker = Temporal::Worker.new(binary_checksum: `git show HEAD -s --format=%H`.strip)

worker.register_workflow(AsyncActivityWorkflow)
worker.register_workflow(AsyncHelloWorldWorkflow)
worker.register_workflow(BranchingWorkflow)
worker.register_workflow(CallsDelegatorWorkflow)
worker.register_workflow(CallFailingActivityWorkflow)
worker.register_workflow(CancellingTimerWorkflow)
worker.register_workflow(CheckWorkflow)
worker.register_workflow(ChildWorkflowTimeoutWorkflow)
worker.register_workflow(ChildWorkflowTerminatedWorkflow)
worker.register_workflow(ContinueAsNewWorkflow)
worker.register_workflow(FailingActivitiesWorkflow)
worker.register_workflow(FailingWorkflow)
worker.register_workflow(HandlingStructuredErrorWorkflow)
worker.register_workflow(HelloWorldWorkflow)
worker.register_workflow(InvalidContinueAsNewWorkflow)
worker.register_workflow(LocalHelloWorldWorkflow)
worker.register_workflow(LongWorkflow)
worker.register_workflow(LoopWorkflow)
worker.register_workflow(MetadataWorkflow)
worker.register_workflow(ParentCloseWorkflow)
worker.register_workflow(ParentIdReuseWorkflow)
worker.register_workflow(ParentWorkflow)
worker.register_workflow(ProcessFileWorkflow)
worker.register_workflow(QueryWorkflow)
worker.register_workflow(QuickTimeoutWorkflow)
worker.register_workflow(RandomlyFailingWorkflow)
worker.register_workflow(ReleaseWorkflow)
worker.register_workflow(ResultWorkflow)
worker.register_workflow(ScheduleChildWorkflow)
worker.register_workflow(SendSignalToExternalWorkflow)
worker.register_workflow(SerialHelloWorldWorkflow)
worker.register_workflow(SideEffectWorkflow)
worker.register_workflow(SignalWithStartWorkflow)
worker.register_workflow(SignalWorkflow)
worker.register_workflow(SimpleTimerWorkflow)
worker.register_workflow(SlowChildWorkflow)
worker.register_workflow(StartChildWorkflowWorkflow)
worker.register_workflow(TimeoutWorkflow)
worker.register_workflow(TripBookingWorkflow)
worker.register_workflow(UpdatableTimer)
worker.register_workflow(UpsertSearchAttributesWorkflow)
worker.register_workflow(WaitForWorkflow)
worker.register_workflow(WaitForExternalSignalWorkflow)
worker.register_workflow(WaitForNamedSignalWorkflow)
worker.register_dynamic_workflow(DelegatorWorkflow)

worker.register_activity(AsyncActivity)
worker.register_activity(EchoActivity)
worker.register_activity(FailingActivity)
worker.register_activity(FailingWithStructuredErrorActivity)
worker.register_activity(GenerateFileActivity)
worker.register_activity(GuessActivity)
worker.register_activity(HelloWorldActivity)
worker.register_activity(LongRunningActivity)
worker.register_activity(ProcessFileActivity)
worker.register_activity(RandomlyFailingActivity)
worker.register_activity(RandomNumberActivity)
worker.register_activity(TerminateWorkflowActivity)
worker.register_activity(SleepActivity)
worker.register_activity(UploadFileActivity)
worker.register_activity(Trip::BookFlightActivity)
worker.register_activity(Trip::BookHotelActivity)
worker.register_activity(Trip::CancelCarActivity)
worker.register_activity(Trip::CancelFlightActivity)
worker.register_activity(Trip::CancelHotelActivity)
worker.register_activity(Trip::MakePaymentActivity)
worker.register_activity(Trip::RentCarActivity)
worker.register_dynamic_activity(DelegatorActivity)

worker.add_workflow_task_middleware(LoggingMiddleware, 'EXAMPLE')
worker.add_activity_middleware(LoggingMiddleware, 'EXAMPLE')
worker.add_activity_middleware(SamplePropagator)
worker.add_workflow_middleware(SamplePropagator)

worker.start