ただ digdag コマンドを 叩くと 前回実行済みの タスクが実行されない件

run コマンドの オプションを確認してみると —session というものがある。

意訳すると これは 未指定のばあいは、 前回の実行の続きから始める、ということらしい。

Digdag は .digdag ディレクトリ以下で 進行状況を記憶しているのでそこを参照してすでに実行されたタスクに関してはもう実行しないようになる。

注意。

$ digdag run --help
Usage: digdag run <workflow.dig> [+task] [options...]
  Options:
        --project DIR                use this directory as the project directory (default: current directory)
    -a, --rerun                      ignores status files saved at .digdag/status and re-runs all tasks
    -s, --start +NAME                runs this task and its following tasks even if their status files are stored at .digdag/status
    -g, --goal +NAME                 runs this task and its children tasks even if their status files are stored at .digdag/status
    -e, --end +NAME                  skips this task and its following tasks
    -o, --save DIR                   uses this directory to read and write status files (default: .digdag/status)
        --no-save                    doesn't save status files at .digdag/status
    -p, --param KEY=VALUE            overwrites a parameter (use multiple times to set many parameters)
    -P, --params-file PATH.yml       reads parameters from a YAML file
    -d, --dry-run                    dry-run mode doesn't execute tasks
    -E, --show-params                show task parameters before running a task
        --session <daily | hourly | schedule | last | "yyyy-MM-dd[ HH:mm:ss]">  set session_time to this time
                                     (default: last, reuses the latest session time stored at .digdag/status)
    --max-task-threads               Limit maximum number of task execution threads on the execution
    -L, --log PATH                   output log messages to a file (default: -)
    -l, --log-level LEVEL            log level (error, warn, info, debug or trace)
    -X KEY=VALUE                     add a performance system config
    -c, --config PATH.properties     Configuration file (default: /root/.config/digdag/config)