Skip to content

Instantly share code, notes, and snippets.

@arc279
Last active October 31, 2018 06:26
Show Gist options
  • Save arc279/424ac340e49be003e9cd30a10959dd8b to your computer and use it in GitHub Desktop.
Save arc279/424ac340e49be003e9cd30a10959dd8b to your computer and use it in GitHub Desktop.
+t1:
py>: a.ok
arg1: 111
+t2:
py>: a.ng
arg1: 111
arg2: 222
def ok(arg1, arg2=2, arg3=3):
print(arg1, arg2, arg3)
def ng(arg1, arg2, arg3=3):
print(arg1, arg2, arg3)
2018-10-31 15:24:31 +0900 [WARN] (main) io.digdag.cli.Run: Reusing the last session time 2018-10-17T00:00:00+00:00.
2018-10-31 15:24:31 +0900 [INFO] (main) io.digdag.cli.Run: Using session /Users/kuryu/workspace/digdag/.digdag/status/20181017T000000+0000.
2018-10-31 15:24:31 +0900 [INFO] (main) io.digdag.core.workflow.WorkflowExecutor: Starting a new session project id=1 workflow name=a session_time=2018-10-17T00:00:00+00:00
2018-10-31 15:24:32 +0900 [INFO] (0017@[0:default]+a+t1) io.digdag.core.agent.OperatorManager: py>: a.ok
2018-10-31 15:24:32 +0900 [WARN] (0017@[0:default]+a+t1) io.digdag.cli.Run$OperatorManagerWithSkip:
timezone: "UTC"
session_uuid: "f2650fc9-3c02-4812-b37d-077310e67665"
session_time: "2018-10-17T00:00:00+00:00"
session_id: 1
session_date: "2018-10-17"
session_date_compact: "20181017"
session_local_time: "2018-10-17 00:00:00"
session_tz_offset: "+0000"
session_unixtime: 1539734400
last_executed_session_time: ""
last_executed_session_date: ""
last_executed_session_date_compact: ""
last_executed_session_local_time: ""
last_executed_session_tz_offset: "+0000"
last_executed_session_unixtime: ""
project_id: 1
task_name: "+a+t1"
py>: "a.ok"
arg1: 111
_type: "py"
_command: "a.ok"
111 2 3
2018-10-31 15:24:33 +0900 [INFO] (0017@[0:default]+a+t2) io.digdag.core.agent.OperatorManager: py>: a.ng
2018-10-31 15:24:33 +0900 [WARN] (0017@[0:default]+a+t2) io.digdag.cli.Run$OperatorManagerWithSkip:
timezone: "UTC"
session_uuid: "f2650fc9-3c02-4812-b37d-077310e67665"
session_time: "2018-10-17T00:00:00+00:00"
session_id: 1
session_date: "2018-10-17"
session_date_compact: "20181017"
session_local_time: "2018-10-17 00:00:00"
session_tz_offset: "+0000"
session_unixtime: 1539734400
last_executed_session_time: ""
last_executed_session_date: ""
last_executed_session_date_compact: ""
last_executed_session_local_time: ""
last_executed_session_tz_offset: "+0000"
last_executed_session_unixtime: ""
project_id: 1
task_name: "+a+t2"
py>: "a.ng"
arg1: 111
arg2: 222
_type: "py"
_command: "a.ng"
Traceback (most recent call last):
File "<stdin>", line 147, in <module>
File "<stdin>", line 129, in digdag_inspect_arguments
TypeError: Method 'ng' requires parameter 'arg3' but not set
2018-10-31 15:24:33 +0900 [ERROR] (0017@[0:default]+a+t2) io.digdag.core.agent.OperatorManager: Task failed with unexpected error: Python command failed with code 1
java.lang.RuntimeException: Python command failed with code 1
at io.digdag.standards.operator.PyOperatorFactory$PyOperator.runCode(PyOperatorFactory.java:153)
at io.digdag.standards.operator.PyOperatorFactory$PyOperator.runTask(PyOperatorFactory.java:91)
at io.digdag.util.BaseOperator.run(BaseOperator.java:35)
at io.digdag.core.agent.OperatorManager.callExecutor(OperatorManager.java:312)
at io.digdag.cli.Run$OperatorManagerWithSkip.callExecutor(Run.java:694)
at io.digdag.core.agent.OperatorManager.runWithWorkspace(OperatorManager.java:254)
at io.digdag.core.agent.OperatorManager.lambda$runWithHeartbeat$2(OperatorManager.java:137)
at io.digdag.core.agent.LocalWorkspaceManager.withExtractedArchive(LocalWorkspaceManager.java:25)
at io.digdag.core.agent.OperatorManager.runWithHeartbeat(OperatorManager.java:135)
at io.digdag.core.agent.OperatorManager.run(OperatorManager.java:119)
at io.digdag.cli.Run$OperatorManagerWithSkip.run(Run.java:676)
at io.digdag.core.agent.MultiThreadAgent.lambda$null$0(MultiThreadAgent.java:127)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-10-31 15:24:33 +0900 [INFO] (0017@[0:default]+a^failure-alert) io.digdag.core.agent.OperatorManager: type: notify
2018-10-31 15:24:33 +0900 [WARN] (0017@[0:default]+a^failure-alert) io.digdag.cli.Run$OperatorManagerWithSkip:
timezone: "UTC"
session_uuid: "f2650fc9-3c02-4812-b37d-077310e67665"
session_time: "2018-10-17T00:00:00+00:00"
session_id: 1
session_date: "2018-10-17"
session_date_compact: "20181017"
session_local_time: "2018-10-17 00:00:00"
session_tz_offset: "+0000"
session_unixtime: 1539734400
last_executed_session_time: ""
last_executed_session_date: ""
last_executed_session_date_compact: ""
last_executed_session_local_time: ""
last_executed_session_tz_offset: "+0000"
last_executed_session_unixtime: ""
project_id: 1
task_name: "+a^failure-alert"
_type: "notify"
_command: "Workflow session attempt failed"
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment