digdag使い方メモ

REST API のエンドポイント

ドキュメントに情報がないので頑張ってコードから探した division: 5d235dc9d281d2d50f6a2193ad2a312ec51d18ca

	Path
GET	/api/admin/attempts/{id}/userinfo
GET	/api/attempts
GET	/api/attempts/{id}
GET	/api/attempts/{id}/retries
GET	/api/attempts/{id}/tasks
PUT	/api/attempts
POST	/api/attempts/{id}/kill
PUT	/api/logs/{attempt_id}/files
GET	/api/logs/{attempt_id}/upload_handle
GET	/api/logs/{attempt_id}/files
GET	/api/logs/{attempt_id}/files/{file_name}
GET	/api/project
GET	/api/projects
GET	/api/projects/{id}
GET	/api/projects/{id}/revisions
GET	/api/projects/{id}/workflow
GET	/api/projects/{id}/workflows/{name}
GET	/api/projects/{id}/workflows
GET	/api/projects/{id}/schedules
GET	/api/projects/{id}/sessions
GET	/api/projects/{id}/archive
DELETE	/api/projects/{id}
PUT	/api/projects
PUT	/api/projects/{id}/secrets/{key}
DELETE	/api/projects/{id}/secrets/{key}
GET	/api/projects/{id}/secrets
GET	/api/schedules
GET	/api/schedules/{id}
POST	/api/schedules/{id}/skip
POST	/api/schedules/{id}/backfill
POST	/api/schedules/{id}/disable
POST	/api/schedules/{id}/enable
GET	/api/sessions
GET	/api/sessions/{id}
GET	/api/sessions/{id}/attempts
GET	/api/version
GET	/api/version/check
GET	/api/workflow
GET	/api/workflows
GET	/api/workflows/{id}
GET	/api/workflows/{id}/truncated_session_time

digdag push

digdag push すきなプロジェクト名 --project digdag該当ディレクトリ

Secretキーへpy>やsh>からアクセスする

*.digdag

+python-task:
  _env:
    pg_pw: ${secret:pg.password}
  py>: tasks.main

main.py

import digdag
import os

#digdag変数へのアクセス
digdag.env.params['session_id']

#secretにenv経由でアクセス
pw = os.environ.get('pg_pw')