-
Notifications
You must be signed in to change notification settings - Fork 6
Open
Labels
Description
Implement the base infrastructure for push support including abstractions, metadata models, and Celery task plumbing.
Tasks:
-
push-core-define-strategy-pattern
- Implement
PushStrategy
abstract base class - Define
push()
interface
- Implement
-
push-core-implement-hpfs-strategy
- Implement
HPFSPush
subclass - Support atomic copy or
rsync
to target HPFS directory
- Implement
-
push-core-integrate-push-celery
- Add
push_dataset()
Celery task - Wire push stage into workflow pipeline
- Add
-
push-core-idempotency-handling
- Flag file (HPFS), object existence check (cloud), checksum/sync-level (Globus)
-
push-core-database-schema-extension
- Add
push_job
andpush_workflow
Prisma models - Migrate DB and update ORM access
- Add
Implement robust error handling and retry support.
-
push-error-logging
- Centralized error capture and logging
-
push-task-failure-marking
- Update push job record with failure status and cause
-
push-operator-retry-ui
- Admin UI to re-run failed pushes from dashboard