examples/require.yml fails

[danielnorberg]

./pkg/digdag-0.4.2-SNAPSHOT.jar run -f examples/require.yml --all
2016-03-29 10:26:43 +0900: Digdag v0.4.2
2016-03-29 10:26:44 +0900 [WARN] (main): Using a new session time 2016-03-29T00:00:00+09:00.
2016-03-29 10:26:44 +0900 [INFO] (main): Using session digdag.status/20160329T000000+0900.
2016-03-29 10:26:44 +0900 [INFO] (main): Starting a new session repository id=1 workflow name=+require session_time=2016-03-29T00:00:00+09:00
2016-03-29 10:26:45 +0900 [INFO] (0020@+require+task1+require_data): require>: +make_data
2016-03-29 10:26:45 +0900 [INFO] (0020@+require+task1+require_data): Starting a new session repository id=1 workflow name=+make_data session_time=2016-03-29T00:00:00+09:00
2016-03-29 10:26:45 +0900 [ERROR] (0020@+require+task1+require_data): Task failed, retrying
io.digdag.spi.TaskExecutionException: Retrying this task after 1 seconds
    at io.digdag.core.agent.RequireOperatorFactory$RequireOperator.run(RequireOperatorFactory.java:91)
    at io.digdag.core.agent.OperatorManager.callExecutor(OperatorManager.java:238)
    at io.digdag.cli.Run$OperatorManagerWithSkip.callExecutor(Run.java:653)
    at io.digdag.core.agent.OperatorManager.runWithArchive(OperatorManager.java:193)
    at io.digdag.core.agent.OperatorManager.lambda$runWithHeartbeat$1(OperatorManager.java:130)
    at io.digdag.core.agent.CurrentDirectoryArchiveManager.withExtractedArchive(CurrentDirectoryArchiveManager.java:20)
    at io.digdag.core.agent.OperatorManager.runWithHeartbeat(OperatorManager.java:129)
    at io.digdag.core.agent.OperatorManager.run(OperatorManager.java:107)
    at io.digdag.cli.Run$OperatorManagerWithSkip.run(Run.java:635)
    at io.digdag.core.agent.LocalAgent.lambda$run$0(LocalAgent.java:61)
    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:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
2016-03-29 10:26:45 +0900 [ERROR] (0020@+require+task1+require_data): Task failed
org.skife.jdbi.v2.exceptions.UnableToCreateStatementException: org.h2.jdbc.JdbcSQLException: Syntax error in SQL statement "UPDATE TASKS  SET UPDATED_AT = NOW(), STATE = ?, RETRY_AT = TIMESTAMPADD('SECOND', STATE_PARAMS = ?, ?,[*] NOW()) WHERE ID = ? AND STATE = ? "; expected "[, ::, *, /, %, +, -, ||, ~, !~, NOT, LIKE, REGEXP, IS, IN, BETWEEN, AND, OR, )"; SQL statement:
update tasks  set updated_at = now(), state = ?, retry_at = TIMESTAMPADD('SECOND', state_params = ?, ?, now()) where id = ? and state = ? [42001-191] [statement:"update tasks  set updated_at = now(), state = :newState, retry_at = TIMESTAMPADD('SECOND', state_params = :stateParams, :retryInterval, now()) where id = :id and state = :oldState", located:"update tasks  set updated_at = now(), state = :newState, retry_at = TIMESTAMPADD('SECOND', state_params = :stateParams, :retryInterval, now()) where id = :id and state = :oldState", rewritten:"update tasks  set updated_at = now(), state = ?, retry_at = TIMESTAMPADD('SECOND', state_params = ?, ?, now()) where id = ? and state = ?", arguments:{ positional:{}, named:{}, finder:[]}]
    at org.skife.jdbi.v2.SQLStatement.internalExecute(SQLStatement.java:1306)
    at org.skife.jdbi.v2.Update.execute(Update.java:56)
    at io.digdag.core.database.DatabaseSessionStoreManager$DatabaseTaskControlStore.setRetryWaitingState(DatabaseSessionStoreManager.java:695)
    at io.digdag.core.workflow.TaskControl.setRunningToRetryWaiting(TaskControl.java:272)
    at io.digdag.core.workflow.WorkflowExecutor.retryTask(WorkflowExecutor.java:937)
    at io.digdag.core.workflow.WorkflowExecutor.lambda$retryTask$21(WorkflowExecutor.java:849)
    at io.digdag.core.database.DatabaseSessionStoreManager.lambda$lockTaskIfExists$14(DatabaseSessionStoreManager.java:278)
    at io.digdag.core.database.BasicDatabaseStoreManager.lambda$transaction$0(BasicDatabaseStoreManager.java:192)
    at org.skife.jdbi.v2.tweak.transactions.LocalTransactionHandler.inTransaction(LocalTransactionHandler.java:183)
    at org.skife.jdbi.v2.BasicHandle.inTransaction(BasicHandle.java:330)
    at io.digdag.core.database.BasicDatabaseStoreManager.transaction(BasicDatabaseStoreManager.java:192)
    at io.digdag.core.database.DatabaseSessionStoreManager.lockTaskIfExists(DatabaseSessionStoreManager.java:272)
    at io.digdag.core.workflow.WorkflowExecutor.retryTask(WorkflowExecutor.java:848)
    at io.digdag.core.agent.InProcessTaskCallbackApi.retryTask(InProcessTaskCallbackApi.java:113)
    at io.digdag.core.agent.OperatorManager.runWithArchive(OperatorManager.java:209)
    at io.digdag.core.agent.OperatorManager.lambda$runWithHeartbeat$1(OperatorManager.java:130)
    at io.digdag.core.agent.CurrentDirectoryArchiveManager.withExtractedArchive(CurrentDirectoryArchiveManager.java:20)
    at io.digdag.core.agent.OperatorManager.runWithHeartbeat(OperatorManager.java:129)
    at io.digdag.core.agent.OperatorManager.run(OperatorManager.java:107)
    at io.digdag.cli.Run$OperatorManagerWithSkip.run(Run.java:635)
    at io.digdag.core.agent.LocalAgent.lambda$run$0(LocalAgent.java:61)
    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:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: org.h2.jdbc.JdbcSQLException: Syntax error in SQL statement "UPDATE TASKS  SET UPDATED_AT = NOW(), STATE = ?, RETRY_AT = TIMESTAMPADD('SECOND', STATE_PARAMS = ?, ?,[*] NOW()) WHERE ID = ? AND STATE = ? "; expected "[, ::, *, /, %, +, -, ||, ~, !~, NOT, LIKE, REGEXP, IS, IN, BETWEEN, AND, OR, )"; SQL statement:
update tasks  set updated_at = now(), state = ?, retry_at = TIMESTAMPADD('SECOND', state_params = ?, ?, now()) where id = ? and state = ? [42001-191]
    at org.h2.message.DbException.getJdbcSQLException(DbException.java:345)
    at org.h2.message.DbException.getSyntaxError(DbException.java:205)
    at org.h2.command.Parser.getSyntaxError(Parser.java:535)
    at org.h2.command.Parser.read(Parser.java:3170)
    at org.h2.command.Parser.readFunction(Parser.java:2506)
    at org.h2.command.Parser.readTerm(Parser.java:2791)
    at org.h2.command.Parser.readFactor(Parser.java:2308)
    at org.h2.command.Parser.readSum(Parser.java:2295)
    at org.h2.command.Parser.readConcat(Parser.java:2265)
    at org.h2.command.Parser.readCondition(Parser.java:2115)
    at org.h2.command.Parser.readAnd(Parser.java:2087)
    at org.h2.command.Parser.readExpression(Parser.java:2079)
    at org.h2.command.Parser.parseUpdate(Parser.java:751)
    at org.h2.command.Parser.parsePrepared(Parser.java:465)
    at org.h2.command.Parser.parse(Parser.java:315)
    at org.h2.command.Parser.parse(Parser.java:291)
    at org.h2.command.Parser.prepareCommand(Parser.java:252)
    at org.h2.engine.Session.prepareLocal(Session.java:560)
    at org.h2.engine.Session.prepareCommand(Session.java:501)
    at org.h2.jdbc.JdbcConnection.prepareCommand(JdbcConnection.java:1188)
    at org.h2.jdbc.JdbcPreparedStatement.<init>(JdbcPreparedStatement.java:73)
    at org.h2.jdbc.JdbcConnection.prepareStatement(JdbcConnection.java:276)
    at com.zaxxer.hikari.pool.ProxyConnection.prepareStatement(ProxyConnection.java:308)
    at com.zaxxer.hikari.pool.HikariProxyConnection.prepareStatement(HikariProxyConnection.java)
    at org.skife.jdbi.v2.DefaultStatementBuilder.create(DefaultStatementBuilder.java:54)
    at org.skife.jdbi.v2.SQLStatement.internalExecute(SQLStatement.java:1302)
    ... 25 common frames omitted
2016-03-29 10:26:45 +0900 [INFO] (0020@+make_data+step1): sh>: echo "creating data..."
creating data...
error:
  * +require+task1+require_data:
    org.h2.jdbc.JdbcSQLException: Syntax error in SQL statement "UPDATE TASKS  SET UPDATED_AT = NOW(), STATE = ?, RETRY_AT = TIMESTAMPADD('SECOND', STATE_PARAMS = ?, ?,[*] NOW()) WHERE ID = ? AND STATE = ? "; expected "[, ::, *, /, %, +, -, ||, ~, !~, NOT, LIKE, REGEXP, IS, IN, BETWEEN, AND, OR, )"; SQL statement:
update tasks  set updated_at = now(), state = ?, retry_at = TIMESTAMPADD('SECOND', state_params = ?, ?, now()) where id = ? and state = ? [42001-191] [statement:"update tasks  set updated_at = now(), state = :newState, retry_at = TIMESTAMPADD('SECOND', state_params = :stateParams, :retryInterval, now()) where id = :id and state = :oldState", located:"update tasks  set updated_at = now(), state = :newState, retry_at = TIMESTAMPADD('SECOND', state_params = :stateParams, :retryInterval, now()) where id = :id and state = :oldState", rewritten:"update tasks  set updated_at = now(), state = ?, retry_at = TIMESTAMPADD('SECOND', state_params = ?, ?, now()) where id = ? and state = ?", arguments:{ positional:{}, named:{}, finder:[]}]

Task state is saved at digdag.status/20160329T000000+0900 directory.
Run command with --session '2016-03-29 00:00:00' argument to retry failed tasks.