Function scheduleClock

packages/cluster/src/ClusterWorkflowEngine.ts:558–577

(workflow, options)

    ),

    scheduleClock(workflow, options) {
      return DateTime.now.pipe(
        Effect.flatMap((now) =>
          sendDiscard({
            rpc: ClockRpc,
            address: entityAddressFor({
              workflow,
              entityType: ClockEntity.type,
              executionId: options.executionId
            }),
            payload: {
              name: options.clock.name,
              workflowName: workflow.name,
              wakeUp: DateTime.addDuration(now, options.clock.duration)
            }
          })
        ),
        Effect.orDie
      )
    }
  })

  return engine