From d1c9450a79c8bc74b6044ca2a8961c6cc42e32a7 Mon Sep 17 00:00:00 2001 From: Damien Arnodo Date: Sun, 1 Feb 2026 07:01:51 +0000 Subject: [PATCH] fix(deploy): use GitRepository source for remote flow execution The worker needs to fetch flow code from Git since the CI pipeline is ephemeral and local paths are not accessible at runtime. --- deploy.py | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/deploy.py b/deploy.py index c18124d..c8da05f 100644 --- a/deploy.py +++ b/deploy.py @@ -2,14 +2,24 @@ Script de déploiement des flows vers Prefect. """ -from flows.backup import pg_backup +from prefect import flow +from prefect.runner.storage import GitRepository def main(): """Déploie tous les flows.""" - # Déploiement du flow de backup - pg_backup.deploy( + # Source Git pour le code des flows + source = GitRepository( + url="https://gitea.arnodo.fr/Damien/prefect-flows-pg-backup.git", + branch="main", + ) + + # Déploiement du flow de backup depuis le repository Git + flow.from_source( + source=source, + entrypoint="flows/backup.py:pg_backup", + ).deploy( name="pg-backup-daily", work_pool_name="pg-backup-pool", cron="0 2 * * *", # Tous les jours à 2h du matin