Skip to content

Instantly share code, notes, and snippets.

@airhorns
Created April 25, 2022 19:43
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save airhorns/1e68d6d0cd4e67fb91e4ad896db80ec6 to your computer and use it in GitHub Desktop.
Save airhorns/1e68d6d0cd4e67fb91e4ad896db80ec6 to your computer and use it in GitHub Desktop.
[4:23:42.929 PM] INFO (temporal-worker): [temporal_sdk_core::worker] Initializing worker task_queue=default
RUNS api packages/api/spec/services/auth/ResetPassword.spec.ts
[4:23:43.205 PM] INFO (temporal-worker): Worker state changed
userVisible: false
state: "RUNNING"
[4:23:43.208 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] poll_workflow_activation;
RUNS api packages/api/spec/services/auth/ResetPassword.spec.ts
[4:23:44.917 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::workflow_tasks] Applying new workflow task from server task_token=CiQ2Yjk2MjBlMi0zYTUxLTQ0Y2ItYTkwZC0xMDZmNmRlNjE3NjUSIHNlbmQtZW1haWwtRFhJREtGNGZYYlZqUTE1MHFzT2RLGiQ2N2U4YzljZC02MjFiLTQ5YjYtODI1My1kNTg4ZjA3NGQwYTcgAigB history_length=3 start_event_id=Some(1) attempt=1 run_id=67e8c9cd-621b-49b6-8253-d588f074d0a7
userVisible: false
[4:23:44.919 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::workflow_tasks::concurrency_manager] create_or_update machines; run_id=67e8c9cd-621b-49b6-8253-d588f074d0a7
userVisible: false
[4:23:44.920 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] handling non-stateful event event=HistoryEvent(id: 1, Some(WorkflowExecutionStarted))
userVisible: false
[4:23:44.920 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::driven_workflow] Driven WF start run_id=67e8c9cd-621b-49b6-8253-d588f074d0a7
userVisible: false
[4:23:44.921 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] handling non-stateful event event=HistoryEvent(id: 2, Some(WorkflowTaskScheduled))
userVisible: false
[4:23:44.922 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 2, Some(WorkflowTaskScheduled)) machine_name=WorkflowTaskMachine state=Created
userVisible: false
[4:23:44.922 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 3, Some(WorkflowTaskStarted)) machine_name=WorkflowTaskMachine state=Scheduled
userVisible: false
[4:23:44.923 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] Machine produced commands commands=[WFTaskStartedTrigger] state=Started machine_name=WorkflowTaskMachine
userVisible: false
[4:23:44.923 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] Machine produced responses responses=[TriggerWFTaskStarted] machine_name=WorkflowTask
userVisible: false
[4:23:44.924 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] Sending activation to lang activation=WorkflowActivation(run_id: 67e8c9cd-621b-49b6-8253-d588f074d0a7, is_replaying: false, jobs: StartWorkflow)
userVisible: false
[4:23:44.924 PM] DEBUG (temporal-worker): Got workflow activation
userVisible: false
runId: "67e8c9cd-621b-49b6-8253-d588f074d0a7"
jobs: [
{
"startWorkflow": {
"workflowType": "SendEmail",
"workflowId": "send-email-DXIDKF4fXbVjQ150qsOdK",
"arguments": [
{
"metadata": {
"encoding": "anNvbi9wbGFpbg=="
},
"data": "eyJ0byI6InRlc3RAZXhhbXBsZS5jb20iLCJzZW5kZ3JpZCI6eyJ0ZW1wbGF0ZUlkIjoiZC01NTBkNTM1NWNhMTI0YmQ3YWQyNWEwMTRjZWU5MmNjYiIsInRlbXBsYXRlRGF0YSI6eyJ0b2tlbiI6IjVjMDVlYzZmM2E0MjY4NzA4Njk1NzcwYjg1NjFhMmVjODNjYTgzMWNlYmRjZGRiYTk2MDE3YmUxYmZhNjc0NzIzZDc2NGMwODQwMGU0Y2U1Y2Q2YjVmNGIwMzk5MTJhYWQ3ZjJhMjczODI3YmY1MTRmMDFjY2Y5ZmI1ZmMwYjNhIn19LCJub2RlbWFpbGVyIjp7InN1YmplY3QiOiJQYXNzd29yZCBSZXNldCIsInRleHQiOiJUb2tlbjogNWMwNWVjNmYzYTQyNjg3MDg2OTU3NzBiODU2MWEyZWM4M2NhODMxY2ViZGNkZGJhOTYwMTdiZTFiZmE2NzQ3MjNkNzY0YzA4NDAwZTRjZTVjZDZiNWY0YjAzOTkxMmFhZDdmMmEyNzM4MjdiZjUxNGYwMWNjZjlmYjVmYzBiM2EsIHVybDogaHR0cHM6Ly9hcHAuZ2d0LmRldjozMDAwL2F1dGgvcmVzZXQ/dG9rZW49NWMwNWVjNmYzYTQyNjg3MDg2OTU3NzBiODU2MWEyZWM4M2NhODMxY2ViZGNkZGJhOTYwMTdiZTFiZmE2NzQ3MjNkNzY0YzA4NDAwZTRjZTVjZDZiNWY0YjAzOTkxMmFhZDdmMmEyNzM4MjdiZjUxNGYwMWNjZjlmYjVmYzBiM2EiLCJodG1sIjoiPGI+UmVzZXQgcGFzc3dvcmQ6IDxhIGhyZWY9XCJodHRwczovL2FwcC5nZ3QuZGV2OjMwMDAvYXV0aC9yZXNldD90b2tlbj01YzA1ZWM2ZjNhNDI2ODcwODY5NTc3MGI4NTYxYTJlYzgzY2E4MzFjZWJkY2RkYmE5NjAxN2JlMWJmYTY3NDcyM2Q3NjRjMDg0MDBlNGNlNWNkNmI1ZjRiMDM5OTEyYWFkN2YyYTI3MzgyN2JmNTE0ZjAxY2NmOWZiNWZjMGIzYVwiPlJlc2V0IGhlcmU8L2E+PC9iPiJ9fQ=="
}
],
"randomnessSeed": "16645771672340677995",
"identity": "46088@inspector",
"workflowTaskTimeout": {
"seconds": "10"
},
"firstExecutionRunId": "67e8c9cd-621b-49b6-8253-d588f074d0a7",
"attempt": 1,
"cronScheduleToScheduleInterval": {}
}
}
]
[4:23:44.925 PM] DEBUG (temporal-worker): Creating workflow
userVisible: false
workflowType: "SendEmail"
workflowId: "send-email-DXIDKF4fXbVjQ150qsOdK"
runId: "67e8c9cd-621b-49b6-8253-d588f074d0a7"
[4:23:44.926 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] poll_workflow_activation;
userVisible: false
[4:23:44.952 PM] DEBUG (temporal-worker): Completed activation
userVisible: false
runId: "67e8c9cd-621b-49b6-8253-d588f074d0a7"
[4:23:44.960 PM] DEBUG: activity completed
userVisible: false
label: "temporal-activity"
activity: {
"activityId": "1",
"workflowExecution": {
"workflowId": "send-email-DXIDKF4fXbVjQ150qsOdK",
"runId": "67e8c9cd-621b-49b6-8253-d588f074d0a7"
},
"attempt": 1,
"isLocal": false,
"activityType": "sendEmail",
"workflowType": "SendEmail",
"scheduledTimestampMs": 1650903824953
}
durationMs: 0
[4:23:44.964 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] complete_workflow_activation; completion=WorkflowActivationCompletion(run_id: 67e8c9cd-621b-49b6-8253-d588f074d0a7, status: Success(ScheduleActivity(1, sendEmail) )) run_id=67e8c9cd-621b-49b6-8253-d588f074d0a7
userVisible: false
[4:23:44.966 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::bridge] wf bridge iteration fetch in_cmds=[ScheduleActivity(1, sendEmail)]
userVisible: false
[4:23:44.967 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling command command_type=ScheduleActivityTask machine_name=ActivityMachine state=ScheduleCommandCreated
userVisible: false
[4:23:44.968 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] prepared commands commands=[Cmd&Machine(ScheduleActivityTask)]
userVisible: false
[4:23:44.968 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker::activities::local_activities] Queuing local activities: []
userVisible: false
[4:23:44.969 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] Sending commands to server: [ScheduleActivityTask]
userVisible: false
[4:23:44.970 PM] DEBUG (temporal-worker): Got activity task
userVisible: false
taskToken: "CiQ2Yjk2MjBlMi0zYTUxLTQ0Y2ItYTkwZC0xMDZmNmRlNjE3NjUSIHNlbmQtZW1haWwtRFhJREtGNGZYYlZqUTE1MHFzT2RLGiQ2N2U4YzljZC02MjFiLTQ5YjYtODI1My1kNTg4ZjA3NGQwYTcgBSgBMgExQglzZW5kRW1haWw="
start: {
"workflowNamespace": "gadget-test",
"workflowType": "SendEmail",
"workflowExecution": {
"workflowId": "send-email-DXIDKF4fXbVjQ150qsOdK",
"runId": "67e8c9cd-621b-49b6-8253-d588f074d0a7"
},
"activityId": "1",
"activityType": "sendEmail",
"input": [
{
"metadata": {
"encoding": "anNvbi9wbGFpbg=="
},
"data": "eyJ0byI6InRlc3RAZXhhbXBsZS5jb20iLCJzZW5kZ3JpZCI6eyJ0ZW1wbGF0ZUlkIjoiZC01NTBkNTM1NWNhMTI0YmQ3YWQyNWEwMTRjZWU5MmNjYiIsInRlbXBsYXRlRGF0YSI6eyJ0b2tlbiI6IjVjMDVlYzZmM2E0MjY4NzA4Njk1NzcwYjg1NjFhMmVjODNjYTgzMWNlYmRjZGRiYTk2MDE3YmUxYmZhNjc0NzIzZDc2NGMwODQwMGU0Y2U1Y2Q2YjVmNGIwMzk5MTJhYWQ3ZjJhMjczODI3YmY1MTRmMDFjY2Y5ZmI1ZmMwYjNhIn19LCJub2RlbWFpbGVyIjp7InN1YmplY3QiOiJQYXNzd29yZCBSZXNldCIsInRleHQiOiJUb2tlbjogNWMwNWVjNmYzYTQyNjg3MDg2OTU3NzBiODU2MWEyZWM4M2NhODMxY2ViZGNkZGJhOTYwMTdiZTFiZmE2NzQ3MjNkNzY0YzA4NDAwZTRjZTVjZDZiNWY0YjAzOTkxMmFhZDdmMmEyNzM4MjdiZjUxNGYwMWNjZjlmYjVmYzBiM2EsIHVybDogaHR0cHM6Ly9hcHAuZ2d0LmRldjozMDAwL2F1dGgvcmVzZXQ/dG9rZW49NWMwNWVjNmYzYTQyNjg3MDg2OTU3NzBiODU2MWEyZWM4M2NhODMxY2ViZGNkZGJhOTYwMTdiZTFiZmE2NzQ3MjNkNzY0YzA4NDAwZTRjZTVjZDZiNWY0YjAzOTkxMmFhZDdmMmEyNzM4MjdiZjUxNGYwMWNjZjlmYjVmYzBiM2EiLCJodG1sIjoiPGI+UmVzZXQgcGFzc3dvcmQ6IDxhIGhyZWY9XCJodHRwczovL2FwcC5nZ3QuZGV2OjMwMDAvYXV0aC9yZXNldD90b2tlbj01YzA1ZWM2ZjNhNDI2ODcwODY5NTc3MGI4NTYxYTJlYzgzY2E4MzFjZWJkY2RkYmE5NjAxN2JlMWJmYTY3NDcyM2Q3NjRjMDg0MDBlNGNlNWNkNmI1ZjRiMDM5OTEyYWFkN2YyYTI3MzgyN2JmNTE0ZjAxY2NmOWZiNWZjMGIzYVwiPlJlc2V0IGhlcmU8L2E+PC9iPiJ9fQ=="
}
],
"scheduledTime": {
"seconds": "1650903824",
"nanos": 953455000
},
"currentAttemptScheduledTime": {
"seconds": "1650903824",
"nanos": 953455000
},
"startedTime": {
"seconds": "1650903824",
"nanos": 956312000
},
"attempt": 1,
"scheduleToCloseTimeout": {
"seconds": "60",
"nanos": 2857000
},
"startToCloseTimeout": {
"seconds": "60"
},
"heartbeatTimeout": {}
}
[4:23:44.971 PM] DEBUG (temporal-worker): Starting activity
userVisible: false
activityId: "1"
activityType: "sendEmail"
[4:23:44.971 PM] DEBUG (temporal-worker): Activity resolved
userVisible: false
activityId: "1"
status: "completed"
[4:23:44.974 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] complete_activity_task; completion=ActivityTaskCompletion(token: CiQ2Yjk2MjBlMi0zYTUxLTQ0Y2ItYTkwZC0xMDZmNmRlNjE3NjUSIHNlbmQtZW1haWwtRFhJREtGNGZYYlZqUTE1MHFzT2RLGiQ2N2U4YzljZC02MjFiLTQ5YjYtODI1My1kNTg4ZjA3NGQwYTcgBSgBMgExQglzZW5kRW1haWw=, ActivityExecutionResult(Success([])))
userVisible: false
[4:23:44.979 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::workflow_tasks] Applying new workflow task from server task_token=CiQ2Yjk2MjBlMi0zYTUxLTQ0Y2ItYTkwZC0xMDZmNmRlNjE3NjUSIHNlbmQtZW1haWwtRFhJREtGNGZYYlZqUTE1MHFzT2RLGiQ2N2U4YzljZC02MjFiLTQ5YjYtODI1My1kNTg4ZjA3NGQwYTcgCCgB history_length=6 start_event_id=Some(4) attempt=1 run_id=67e8c9cd-621b-49b6-8253-d588f074d0a7
userVisible: false
[4:23:44.981 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::workflow_tasks::concurrency_manager] create_or_update machines; run_id=67e8c9cd-621b-49b6-8253-d588f074d0a7
userVisible: false
[4:23:44.981 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 4, Some(WorkflowTaskCompleted)) machine_name=WorkflowTaskMachine state=Started
userVisible: false
[4:23:44.982 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] Machine produced commands commands=[WFTaskStartedTrigger] state=Completed machine_name=WorkflowTaskMachine
userVisible: false
[4:23:44.983 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] Machine produced responses responses=[TriggerWFTaskStarted] machine_name=WorkflowTask
userVisible: false
[4:23:44.984 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 5, Some(ActivityTaskScheduled)) machine_name=ActivityMachine state=ScheduleCommandCreated
userVisible: false
[4:23:44.984 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 6, Some(ActivityTaskStarted)) machine_name=ActivityMachine state=ScheduledEventRecorded
userVisible: false
[4:23:44.985 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 7, Some(ActivityTaskCompleted)) machine_name=ActivityMachine state=Started
userVisible: false
[4:23:44.986 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] Machine produced commands commands=[Complete] state=Completed machine_name=ActivityMachine
userVisible: false
[4:23:44.986 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] Machine produced responses responses=[PushWFJob(ResolveActivity(1))] machine_name=Activity
userVisible: false
[4:23:44.987 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] handling non-stateful event event=HistoryEvent(id: 8, Some(WorkflowTaskScheduled))
userVisible: false
[4:23:44.987 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 8, Some(WorkflowTaskScheduled)) machine_name=WorkflowTaskMachine state=Created
userVisible: false
[4:23:44.988 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling event event=HistoryEvent(id: 9, Some(WorkflowTaskStarted)) machine_name=WorkflowTaskMachine state=Scheduled
userVisible: false
[4:23:44.989 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] Machine produced commands commands=[WFTaskStartedTrigger] state=Started machine_name=WorkflowTaskMachine
userVisible: false
[4:23:44.989 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] Machine produced responses responses=[TriggerWFTaskStarted] machine_name=WorkflowTask
userVisible: false
[4:23:44.990 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] Sending activation to lang activation=WorkflowActivation(run_id: 67e8c9cd-621b-49b6-8253-d588f074d0a7, is_replaying: false, jobs: ResolveActivity(1))
userVisible: false
[4:23:44.990 PM] DEBUG (temporal-worker): Got workflow activation
userVisible: false
runId: "67e8c9cd-621b-49b6-8253-d588f074d0a7"
jobs: [
{
"resolveActivity": {
"seq": 1,
"result": {
"completed": {
"result": {
"metadata": {
"encoding": "YmluYXJ5L251bGw="
}
}
}
}
}
}
]
[4:23:44.991 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] poll_workflow_activation;
userVisible: false
[4:23:44.992 PM] DEBUG (temporal-worker): Completed activation
userVisible: false
runId: "67e8c9cd-621b-49b6-8253-d588f074d0a7"
[4:23:44.999 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] complete_workflow_activation; completion=WorkflowActivationCompletion(run_id: 67e8c9cd-621b-49b6-8253-d588f074d0a7, status: Success(CompleteWorkflowExecution )) run_id=67e8c9cd-621b-49b6-8253-d588f074d0a7
userVisible: false
[4:23:45.001 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::bridge] wf bridge iteration fetch in_cmds=[CompleteWorkflowExecution]
userVisible: false
[4:23:45.002 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines] handling command command_type=CompleteWorkflowExecution machine_name=CompleteWorkflowMachine state=CompleteWorkflowCommandCreated
userVisible: false
[4:23:45.002 PM] DEBUG (temporal-worker): [temporal_sdk_core::workflow::machines::workflow_machines] prepared commands commands=[Cmd&Machine(CompleteWorkflowExecution)]
userVisible: false
[4:23:45.004 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker::activities::local_activities] Queuing local activities: []
userVisible: false
[4:23:45.005 PM] DEBUG (temporal-worker): [temporal_sdk_core::worker] Sending commands to server: [CompleteWorkflowExecution]
userVisible: false
[4:23:45.009 PM] DEBUG: got open workflow results
userVisible: false
results: [
null
]
[4:23:45.011 PM] DEBUG: starting worker shutdown cause we're done running stuff
userVisible: false
[4:23:45.016 PM] INFO (temporal-worker): Worker state changed
userVisible: false
state: "STOPPING"
[4:23:45.018 PM] INFO (temporal-worker): [temporal_sdk_core::worker] Initiated shutdown
userVisible: false
[4:23:45.018 PM] INFO (temporal-worker): Worker state changed
userVisible: false
state: "DRAINING"
[4:23:45.019 PM] DEBUG (temporal-worker): Cancelling activity
userVisible: false
taskToken: "CiQ2Yjk2MjBlMi0zYTUxLTQ0Y2ItYTkwZC0xMDZmNmRlNjE3NjUSIHNlbmQtZW1haWwtRFhJREtGNGZYYlZqUTE1MHFzT2RLGiQ2N2U4YzljZC02MjFiLTQ5YjYtODI1My1kNTg4ZjA3NGQwYTcgBSgBMgExQglzZW5kRW1haWw="
[4:23:45.020 PM] ERROR (temporal-worker): Worker failed
userVisible: false
error: {
"name": "ShutdownError",
"message": "Core is shut down",
"stack":
ShutdownError: Core is shut down
}
[4:23:45.020 PM] INFO (temporal-worker): Worker state changed
userVisible: false
state: "FAILED"
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment