Task・DAG運用とCode Bundle管理をPython APIで自動化

従来は、TaskやDAGの細かなスケジュール制御、依存関係の再帰取得、Code Bundleのライフサイクル管理をPython APIだけで一貫して扱えない場合がありました。v1.13.0では、秒単位の実行間隔やroot taskのWHEN条件、重複実行ポリシーをAPIで定義でき、Code Bundleの登録から実行管理までを自動化できます。

• Snowflakeのデータ基盤・ワークフロー運用チーム
• ETL／ELTパイプライン開発者
• Snowflake上のアプリケーション開発者
• CI/CDおよびジョブ実行基盤の担当者

• 対象バージョンはSnowflake Python APIs 1.13.0、公開日は2026年8月10日です。
• 提供ステータスはリリースノートに記載なしです。
• 必要なSnowflakeエディションはリリースノートに記載なしです。
• 対応リージョンはリリースノートに記載なしです。
• Code Bundle、Task、DAGのサーバー側要件や必要権限はリリースノートに記載なしです。

• 短い間隔でデータ処理を起動するTaskを、秒単位かつ1分未満の間隔で定義する。
• DAGのroot taskにWHEN条件とoverlap_policyを設定し、条件成立時だけ実行するとともに重複実行を制御する。
• Taskの依存関係をrecursive=Trueで取得し、影響範囲分析や運用監視に利用する。
• Code Bundleをスキーマ配下でバージョン管理し、ステージ上のBundleを実行して状態確認やキャンセルを自動化する。
• 非同期ジョブの完了待ちをアプリケーション側で制御し、API呼び出しではジョブIDだけを即時取得する。

Task・DAG APIでは、DAGのcondition、Taskおよびroot taskのoverlap_policy、TaskとDAGTaskのsuccess_integrationおよびexecute_as_userを設定できます。Taskのスケジュールとtarget completion intervalは秒単位で定義できます。依存タスクを再帰的に取得する場合は、TaskResource.fetch_task_dependentsのrecursive引数を使用します。Code Bundleは root.databases[<db>].schemas[<schema>].code_bundles から作成、一覧取得、取得、バージョン追加、実行、削除を行い、実行管理は root.code_bundle_execution から行います。非同期実行で asyncExec=true を指定し、HTTP 202 Acceptedを受け取った際にポーリングせず応答を返すには、環境変数 _SNOWFLAKE_SKIP_ASYNC_EXEC_POLLING=true を設定します。

1. Snowflake Python APIsの依存バージョンを1.13.0に固定し、既存コードとの互換性を確認する。
2. 対象のTask・DAG・Code Bundle操作に必要なSnowflake権限とサーバー側対応状況を公式ドキュメントで確認する。
3. 開発用環境で秒単位スケジュール、WHEN条件、overlap_policy、依存関係取得を小規模に検証する。
4. Code Bundleの作成、バージョン追加、実行、状態取得、キャンセル、削除を一連のテストとして実行する。
5. 非同期処理を利用する場合は環境変数を設定し、ジョブID取得後の状態監視とエラー処理を実装する。

• エディション、リージョン、提供ステータス、Preview該当性はリリースノートに記載されていません。
• 各APIの詳細なメソッドシグネチャ、戻り値、必要権限、Code Bundleの構成要件はリリースノートだけでは確認できません。
• 非同期ポーリングの省略は、asyncExec=true と202 Acceptedの応答に限定されます。
• Snowflake Python APIs v1.13.0で追加された機能であり、利用中のSnowflakeアカウントや対象オブジェクトがサーバー側で利用可能かどうかは別途確認が必要です。

• Snowflake Python APIsの公式ドキュメントで、Task、DAG、Code Bundleの具体的なAPI仕様とサンプルを確認する。
• 対象アカウントのSnowflakeリリース、エディション、リージョン、必要権限、およびCode Bundle対応状況を確認する。
• 既存パイプラインを複製した検証環境で、スケジュール、依存関係、重複実行、非同期ジョブの挙動をテストする。
• v1.13.0のセキュリティ改善による入力検証変更が、既存のリソース名やstage pathに影響しないか確認する。

仕様・提供条件は更新される可能性があります。導入前に必ず公式リリースノートを確認してください。

https://docs.snowflake.com/release-notes/clients-drivers/snowapi-python-2026