-
Notifications
You must be signed in to change notification settings - Fork 83
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
ac80def
commit b30f62e
Showing
1,060 changed files
with
14,093 additions
and
358 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,94 @@ | ||
DEBUG temporalio.worker._activity:_activity.py:276 Running activity wait_cancel (token b'local_act_\x01\x00\x00\x00') | ||
DEBUG temporalio.activity:_activity.py:440 Starting activity ({'activity_id': '1', 'activity_type': 'wait_cancel', 'attempt': 1, 'namespace': 'default', 'task_queue': 'ee9eaf5c-c356-4aaf-ad67-d0ad8cc8ea30', 'workflow_id': 'workflow-d2f16aac-f904-450a-b946-3e3e4fe35041', 'workflow_run_id': '26452c66-fdec-4d13-95f9-dce9a6c205e6', 'workflow_type': 'CancelActivityWorkflow'}) | ||
DEBUG temporalio.worker._activity:_activity.py:216 Cancelling activity b'local_act_\x01\x00\x00\x00', reason: 1 | ||
DEBUG temporalio.worker._activity:_activity.py:527 Completing activity with completion: task_token: "local_act_\001\000\000\000" | ||
result { | ||
completed { | ||
result { | ||
metadata { | ||
key: "encoding" | ||
value: "json/plain" | ||
} | ||
data: "\"Got cancelled error, cancelled? True\"" | ||
} | ||
} | ||
} | ||
|
||
DEBUG temporalio.worker._workflow_instance:_workflow_instance.py:1788 Workflow raised failure with run ID 26452c66-fdec-4d13-95f9-dce9a6c205e6 | ||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1767, in _run_top_level_workflow_function | ||
await coro | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 831, in run_workflow | ||
result = await self._inbound.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/testing/_workflow.py", line 493, in execute_workflow | ||
return await super().execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_interceptor.py", line 328, in execute_workflow | ||
return await self.next.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 2099, in execute_workflow | ||
return await input.run_fn(*args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/worker/test_workflow.py", line 881, in run | ||
await asyncio.Future() | ||
asyncio.exceptions.CancelledError | ||
DEBUG temporalio.worker._activity:_activity.py:276 Running activity wait_cancel (token b'local_act_\x02\x00\x00\x00') | ||
DEBUG temporalio.activity:_activity.py:440 Starting activity ({'activity_id': '1', 'activity_type': 'wait_cancel', 'attempt': 1, 'namespace': 'default', 'task_queue': 'ee9eaf5c-c356-4aaf-ad67-d0ad8cc8ea30', 'workflow_id': 'workflow-861c9300-3e52-482d-8a15-e6a312c2674e', 'workflow_run_id': '3167a884-ac06-408e-8e95-f17850b41d9c', 'workflow_type': 'CancelActivityWorkflow'}) | ||
DEBUG temporalio.worker._activity:_activity.py:216 Cancelling activity b'local_act_\x02\x00\x00\x00', reason: 1 | ||
DEBUG temporalio.worker._activity:_activity.py:527 Completing activity with completion: task_token: "local_act_\002\000\000\000" | ||
result { | ||
completed { | ||
result { | ||
metadata { | ||
key: "encoding" | ||
value: "json/plain" | ||
} | ||
data: "\"Got cancelled error, cancelled? True\"" | ||
} | ||
} | ||
} | ||
|
||
DEBUG temporalio.worker._workflow_instance:_workflow_instance.py:1788 Workflow raised failure with run ID 3167a884-ac06-408e-8e95-f17850b41d9c | ||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1767, in _run_top_level_workflow_function | ||
await coro | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 831, in run_workflow | ||
result = await self._inbound.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/testing/_workflow.py", line 493, in execute_workflow | ||
return await super().execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_interceptor.py", line 328, in execute_workflow | ||
return await self.next.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 2099, in execute_workflow | ||
return await input.run_fn(*args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/worker/test_workflow.py", line 881, in run | ||
await asyncio.Future() | ||
asyncio.exceptions.CancelledError | ||
DEBUG temporalio.worker._activity:_activity.py:276 Running activity wait_cancel (token b'local_act_\x03\x00\x00\x00') | ||
DEBUG temporalio.activity:_activity.py:440 Starting activity ({'activity_id': '1', 'activity_type': 'wait_cancel', 'attempt': 1, 'namespace': 'default', 'task_queue': 'ee9eaf5c-c356-4aaf-ad67-d0ad8cc8ea30', 'workflow_id': 'workflow-f95abcf5-7b8c-46bb-a80f-c00ac0607d39', 'workflow_run_id': 'a86d5616-2bb1-4a55-94b2-ef77cacbb287', 'workflow_type': 'CancelActivityWorkflow'}) | ||
DEBUG temporalio.worker._workflow_instance:_workflow_instance.py:1788 Workflow raised failure with run ID a86d5616-2bb1-4a55-94b2-ef77cacbb287 | ||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1767, in _run_top_level_workflow_function | ||
await coro | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 831, in run_workflow | ||
result = await self._inbound.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/testing/_workflow.py", line 493, in execute_workflow | ||
return await super().execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_interceptor.py", line 328, in execute_workflow | ||
return await self.next.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 2099, in execute_workflow | ||
return await input.run_fn(*args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/worker/test_workflow.py", line 881, in run | ||
await asyncio.Future() | ||
asyncio.exceptions.CancelledError | ||
DEBUG temporalio.worker._activity:_activity.py:216 Cancelling activity b'local_act_\x03\x00\x00\x00', reason: 1 | ||
DEBUG temporalio.worker._activity:_activity.py:527 Completing activity with completion: task_token: "local_act_\003\000\000\000" | ||
result { | ||
completed { | ||
result { | ||
metadata { | ||
key: "encoding" | ||
value: "json/plain" | ||
} | ||
data: "\"Got cancelled error, cancelled? True\"" | ||
} | ||
} | ||
} | ||
|
||
INFO temporalio.worker._worker:_worker.py:523 Beginning worker shutdown, will wait 0:00:00 before cancelling activities |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,3 @@ | ||
DEBUG temporalio.worker._workflow:_workflow.py:299 Evicting workflow with run ID be40cdcd-cc70-43e7-ad09-e73032c8a837, message: Workflow cache full | ||
DEBUG temporalio.worker._workflow:_workflow.py:299 Evicting workflow with run ID be40cdcd-cc70-43e7-ad09-e73032c8a837, message: Workflow cache full | ||
INFO temporalio.worker._worker:_worker.py:523 Beginning worker shutdown, will wait 0:00:00 before cancelling activities |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,50 @@ | ||
DEBUG temporalio.worker._activity:_activity.py:276 Running activity raise_error (token b'\x00\x07default\x00$950665e9-ac62-4a57-8fd5-f631a5335ac5\x00$a0805cbd-5ef9-4b5c-b8a7-f5090c0f89f0\x00\x00\x00\x00\x00\x00\x00\x05\x00\x00\x00\x01') | ||
DEBUG temporalio.activity:_activity.py:440 Starting activity ({'activity_id': '1', 'activity_type': 'raise_error', 'attempt': 1, 'namespace': 'default', 'task_queue': '48251a0b-a198-4d74-9e51-629e9bdc6a17', 'workflow_id': '950665e9-ac62-4a57-8fd5-f631a5335ac5', 'workflow_run_id': 'a0805cbd-5ef9-4b5c-b8a7-f5090c0f89f0', 'workflow_type': 'kitchen_sink'}) | ||
WARNING temporalio.activity:_activity.py:493 Completing activity as failed ({'activity_id': '1', 'activity_type': 'raise_error', 'attempt': 1, 'namespace': 'default', 'task_queue': '48251a0b-a198-4d74-9e51-629e9bdc6a17', 'workflow_id': '950665e9-ac62-4a57-8fd5-f631a5335ac5', 'workflow_run_id': 'a0805cbd-5ef9-4b5c-b8a7-f5090c0f89f0', 'workflow_type': 'kitchen_sink'}) | ||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_activity.py", line 453, in _run_activity | ||
result = await impl.execute_activity(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_activity.py", line 711, in execute_activity | ||
return await input.fn(*input.args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/worker/test_activity.py", line 205, in raise_error | ||
raise RuntimeError("oh no!") | ||
RuntimeError: oh no! | ||
DEBUG temporalio.worker._activity:_activity.py:527 Completing activity with completion: task_token: "\000\007default\000$950665e9-ac62-4a57-8fd5-f631a5335ac5\000$a0805cbd-5ef9-4b5c-b8a7-f5090c0f89f0\000\000\000\000\000\000\000\005\000\000\000\001" | ||
result { | ||
failed { | ||
failure { | ||
message: "oh no!" | ||
stack_trace: " File \"/home/runner/work/sdk-python/sdk-python/temporalio/worker/_activity.py\", line 453, in _run_activity\n result = await impl.execute_activity(input)\n\n File \"/home/runner/work/sdk-python/sdk-python/temporalio/worker/_activity.py\", line 711, in execute_activity\n return await input.fn(*input.args)\n\n File \"/home/runner/work/sdk-python/sdk-python/tests/worker/test_activity.py\", line 205, in raise_error\n raise RuntimeError(\"oh no!\")\n" | ||
application_failure_info { | ||
type: "RuntimeError" | ||
} | ||
} | ||
} | ||
} | ||
|
||
DEBUG temporalio.worker._workflow_instance:_workflow_instance.py:1788 Workflow raised failure with run ID a0805cbd-5ef9-4b5c-b8a7-f5090c0f89f0 | ||
temporalio.exceptions.ApplicationError: RuntimeError: oh no! | ||
|
||
The above exception was the direct cause of the following exception: | ||
|
||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1767, in _run_top_level_workflow_function | ||
await coro | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 831, in run_workflow | ||
result = await self._inbound.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/testing/_workflow.py", line 493, in execute_workflow | ||
return await super().execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_interceptor.py", line 328, in execute_workflow | ||
return await self.next.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 2099, in execute_workflow | ||
return await input.run_fn(*args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/helpers/worker.py", line 97, in run | ||
should_return, ret = await self.handle_action(params, action) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/helpers/worker.py", line 204, in handle_action | ||
raise task.exception() # type: ignore | ||
File "/home/runner/work/sdk-python/sdk-python/tests/helpers/worker.py", line 193, in run_activity | ||
last_result = await task | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1423, in run_activity | ||
return await asyncio.shield(handle._result_fut) | ||
temporalio.exceptions.ActivityError: Activity task failed | ||
INFO temporalio.worker._worker:_worker.py:523 Beginning worker shutdown, will wait 0:00:00 before cancelling activities |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,16 @@ | ||
DEBUG temporalio.worker._workflow_instance:_workflow_instance.py:1788 Workflow raised failure with run ID 5209cd29-1c6d-4d79-a939-96ed70291a95 | ||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1767, in _run_top_level_workflow_function | ||
await coro | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 831, in run_workflow | ||
result = await self._inbound.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/testing/_workflow.py", line 493, in execute_workflow | ||
return await super().execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_interceptor.py", line 328, in execute_workflow | ||
return await self.next.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 2099, in execute_workflow | ||
return await input.run_fn(*args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/worker/test_workflow.py", line 5462, in run | ||
raise ApplicationError( | ||
temporalio.exceptions.ApplicationError: Deliberately failing workflow with an unfinished handler | ||
INFO temporalio.worker._worker:_worker.py:523 Beginning worker shutdown, will wait 0:00:00 before cancelling activities |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
DEBUG temporalio.worker._workflow:_workflow.py:299 Evicting workflow with run ID 9a0040ff-5c42-488b-90ae-660e5cba3f14, message: Workflow activation completion failed: Failure { failure: Some(Failure { message: "[TMPRL1100] Nondeterminism error: Timer machine does not handle this event: HistoryEvent(id: 11, WorkflowExecutionCompleted)", source: "", stack_trace: "", encoded_attributes: None, cause: None, failure_info: Some(ApplicationFailureInfo(ApplicationFailureInfo { r#type: "", non_retryable: false, details: None, next_retry_delay: None })) }), force_cause: NonDeterministicError } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,17 @@ | ||
DEBUG temporalio.worker._workflow_instance:_workflow_instance.py:1788 Workflow raised failure with run ID 8c48b197-543b-4699-bf46-e194cb440788 | ||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1767, in _run_top_level_workflow_function | ||
await coro | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 831, in run_workflow | ||
result = await self._inbound.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/testing/_workflow.py", line 493, in execute_workflow | ||
return await super().execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_interceptor.py", line 328, in execute_workflow | ||
return await self.next.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 2099, in execute_workflow | ||
return await input.run_fn(*args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/helpers/worker.py", line 97, in run | ||
should_return, ret = await self.handle_action(params, action) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/helpers/worker.py", line 122, in handle_action | ||
raise ApplicationError(action.error.message or "", *details) | ||
temporalio.exceptions.ApplicationError: some error |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,16 @@ | ||
DEBUG temporalio.worker._workflow_instance:_workflow_instance.py:1788 Workflow raised failure with run ID 601a48db-658c-42fc-9843-0285f17f5e73 | ||
Traceback (most recent call last): | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 1767, in _run_top_level_workflow_function | ||
await coro | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 831, in run_workflow | ||
result = await self._inbound.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/testing/_workflow.py", line 493, in execute_workflow | ||
return await super().execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_interceptor.py", line 328, in execute_workflow | ||
return await self.next.execute_workflow(input) | ||
File "/home/runner/work/sdk-python/sdk-python/temporalio/worker/_workflow_instance.py", line 2099, in execute_workflow | ||
return await input.run_fn(*args) | ||
File "/home/runner/work/sdk-python/sdk-python/tests/worker/test_workflow.py", line 5462, in run | ||
raise ApplicationError( | ||
temporalio.exceptions.ApplicationError: Deliberately failing workflow with an unfinished handler | ||
INFO temporalio.worker._worker:_worker.py:523 Beginning worker shutdown, will wait 0:00:00 before cancelling activities |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,12 @@ | ||
DEBUG tests.test_converter:test_converter.py:467 Showing appended exception | ||
temporalio.exceptions.ApplicationError: ValueError: error1 | ||
Stack: | ||
File "/home/runner/work/sdk-python/sdk-python/tests/test_converter.py", line 438, in test_exception_format | ||
raise ValueError("error1") | ||
|
||
The above exception was the direct cause of the following exception: | ||
|
||
temporalio.exceptions.ApplicationError: RuntimeError: error2 | ||
Stack: | ||
File "/home/runner/work/sdk-python/sdk-python/tests/test_converter.py", line 440, in test_exception_format | ||
raise RuntimeError("error2") from err |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
INFO temporalio.worker._worker:_worker.py:523 Beginning worker shutdown, will wait 0:00:00 before cancelling activities |
Oops, something went wrong.