GovOPlaN/govoplan-dataflow
1
0
Fork 0
Code Issues 10 Pull Requests Actions Packages Projects Releases Wiki Activity

[Feature] Add governed manual, scheduled, event, API, and chained Dataflow triggers #11

New Issue
Open
opened 2026-07-28 14:02:56 +02:00 by zemion · 1 comment
zemion commented 2026-07-28 14:02:56 +02:00
Owner
Copy Link

Parent: #10

Persist and dispatch governed Dataflow trigger definitions. Invocation provenance must distinguish interactive user, API, scheduled, event, Workflow, dependency/upstream, retry/replay, and backfill runs.

Acceptance criteria:

  • manual/API run origin is persisted on every run
  • one-time and interval schedules support timezone, next-fire calculation, catch-up policy, enable/disable, and pinned immutable pipeline revision
  • event triggers accept exact allowlisted event types and constrained equality filters with idempotent event IDs
  • Workflow/dependency invocation uses the versioned run capability and records correlation/causation references
  • triggers cannot target templates and automated execution requires an active complete flow
  • execution resolves current authorization through Access, applies Policy, and fails closed if either required provider is unavailable
  • overlap, concurrency, quota, retry/quarantine, cancellation, notifications, and audit evidence are explicit
  • schedule dispatch runs in a worker; arbitrary SQL and large execution never run in the API process
Parent: https://git.add-ideas.de/GovOPlaN/govoplan-dataflow/issues/10 Persist and dispatch governed Dataflow trigger definitions. Invocation provenance must distinguish interactive user, API, scheduled, event, Workflow, dependency/upstream, retry/replay, and backfill runs. Acceptance criteria: - manual/API run origin is persisted on every run - one-time and interval schedules support timezone, next-fire calculation, catch-up policy, enable/disable, and pinned immutable pipeline revision - event triggers accept exact allowlisted event types and constrained equality filters with idempotent event IDs - Workflow/dependency invocation uses the versioned run capability and records correlation/causation references - triggers cannot target templates and automated execution requires an active complete flow - execution resolves current authorization through Access, applies Policy, and fails closed if either required provider is unavailable - overlap, concurrency, quota, retry/quarantine, cancellation, notifications, and audit evidence are explicit - schedule dispatch runs in a worker; arbitrary SQL and large execution never run in the API process
zemion commented 2026-07-28 15:06:40 +02:00
Author
Owner
Copy Link

Large first slice implemented in govoplan-core@26ae034, govoplan-access@fdfcfbb, govoplan-policy@d6e09fb, govoplan-datasources@6294362, and govoplan-dataflow@08ddc8d.

Completed:

  • persisted manual, API, and administrative backfill run provenance
  • durable one-time, interval, and event triggers pinned to immutable revisions
  • timezone-aware next-fire calculation without unbounded anchor loops
  • coalesce/skip catch-up behavior with durable skipped-delivery evidence
  • enable/disable, optimistic trigger revisions, explicit concurrency ceiling, idempotent event IDs, and exact scalar filters
  • Celery beat/worker dispatch capability and dedicated dataflow queue
  • current Access authorization plus Policy recheck for every delivery
  • least-privilege source/publication grants and template/inactive-flow denial
  • correlation/causation, audit events, delivery status/error, and trigger UI

Remaining before closure:

  • durable transactional event ingress via govoplan-core#270
  • actual Workflow/dependency invocation path
  • asynchronous large-run queue, retries/quarantine, quotas, cancellation, progress, and notifications under govoplan-dataflow#10
  • manual replay/recovery controls

Verification: 35 Dataflow tests, WebUI typecheck/structure checks, migrations, and consolidated focused suite pass.

Large first slice implemented in govoplan-core@26ae034, govoplan-access@fdfcfbb, govoplan-policy@d6e09fb, govoplan-datasources@6294362, and govoplan-dataflow@08ddc8d. Completed: - persisted manual, API, and administrative backfill run provenance - durable one-time, interval, and event triggers pinned to immutable revisions - timezone-aware next-fire calculation without unbounded anchor loops - coalesce/skip catch-up behavior with durable skipped-delivery evidence - enable/disable, optimistic trigger revisions, explicit concurrency ceiling, idempotent event IDs, and exact scalar filters - Celery beat/worker dispatch capability and dedicated dataflow queue - current Access authorization plus Policy recheck for every delivery - least-privilege source/publication grants and template/inactive-flow denial - correlation/causation, audit events, delivery status/error, and trigger UI Remaining before closure: - durable transactional event ingress via govoplan-core#270 - actual Workflow/dependency invocation path - asynchronous large-run queue, retries/quarantine, quotas, cancellation, progress, and notifications under govoplan-dataflow#10 - manual replay/recovery controls Verification: 35 Dataflow tests, WebUI typecheck/structure checks, migrations, and consolidated focused suite pass.
Sign in to join this conversation.
No Branch/Tag Specified
Branches Tags
Labels
Clear labels
area/api
HTTP API contracts, routers, schemas, or API smoke behavior.
area/auth
Authentication, sessions, access bootstrap, or login behavior.
area/db
Database sessions, models, transactions, or persistence primitives.
area/devex
Local developer workflow, scripts, tests, tooling, or release helpers.
area/docs
Durable documentation and project guidance.
area/governance
Governance policy, audit, privacy, retention, or compliance behavior.
area/marketing
Public website, product messaging, publication copy, or legal page content.
area/migrations
Alembic migrations, schema bootstrap, or persistence evolution.
area/module-system
Module discovery, manifests, capabilities, routing, or optional integrations.
area/rbac
Permissions, roles, delegation, or authorization policy.
area/release
Versioning, release locks, tags, packaging, or dependency pins.
area/security
Security posture, static analysis, supply-chain hardening, or vulnerability remediation.
area/tenancy
Tenant boundaries, provisioning, or tenant-scoped data behavior.
area/webui
Shared WebUI shell, frontend components, routing, or frontend tests.
audit/complexity
Complexity finding from Radon, Xenon, or equivalent maintainability scans.
audit/duplication
Duplicated-code finding from jscpd or equivalent similarity scans.
audit/false-positive
Audit finding reviewed as a narrow false positive or acceptable risk.
audit/needs-design
Audit finding that needs an architectural or product decision before implementation.
audit/quick-fix
Audit finding that appears narrow and directly fixable.
audit/structural
Audit finding that needs design, refactoring, or behavior review.
codex/needs-human
Needs an explicit human decision before Codex should implement.
codex/ready
Suitable for Codex to pick up with the existing issue context.
module/access
GovOPlaN access, identity, authentication, RBAC, and administration behavior.
module/addresses
GovOPlaN Addresses module behavior or integration.
module/admin
GovOPlaN Admin module behavior or integration.
module/appointments
GovOPlaN Appointments module behavior or integration.
module/audit
GovOPlaN Audit module behavior or integration.
module/calendar
GovOPlaN Calendar module behavior or integration.
module/campaign
GovOPlaN campaign module behavior or integration.
module/cases
GovOPlaN Cases module behavior or integration.
module/connectors
GovOPlaN Connectors module behavior or integration.
module/core
GovOPlaN core runner, shared primitives, shell, or extension points.
module/dataflow
GovOPlaN Dataflow module behavior or integration.
module/datasources
GovOPlaN governed datasource contracts, catalogs, and integrations.
module/dist-lists
GovOPlaN Distribution Lists module behavior or integration.
module/dms
GovOPlaN Dms module behavior or integration.
module/erp
GovOPlaN Erp module behavior or integration.
module/evaluation
GovOPlaN Evaluation module behavior or integration.
module/files
GovOPlaN files module behavior or integration.
module/fit-connect
GovOPlaN Fit Connect module behavior or integration.
module/forms
GovOPlaN Forms module behavior or integration.
module/identity
GovOPlaN Identity module behavior or integration.
module/identity-trust
GovOPlaN Identity Trust module behavior or integration.
module/idm
GovOPlaN Idm module behavior or integration.
module/ledger
GovOPlaN Ledger module behavior or integration.
module/mail
GovOPlaN mail module behavior or integration.
module/notifications
GovOPlaN Notifications module behavior or integration.
module/ops
GovOPlaN Ops module behavior or integration.
module/organizations
GovOPlaN Organizations module behavior or integration.
module/payments
GovOPlaN Payments module behavior or integration.
module/permits
GovOPlaN Permits module behavior or integration.
module/policy
GovOPlaN Policy module behavior or integration.
module/poll
GovOPlaN Poll module behavior or integration.
module/portal
GovOPlaN Portal module behavior or integration.
module/postbox
GovOPlaN Postbox module behavior or integration.
module/reporting
GovOPlaN Reporting module behavior or integration.
module/risk-compliance
GovOPlaN Risk Compliance module behavior or integration.
module/scheduling
GovOPlaN Scheduling module behavior or integration.
module/search
GovOPlaN Search module behavior or integration.
module/tasks
GovOPlaN Tasks module behavior or integration.
module/templates
GovOPlaN Templates module behavior or integration.
module/tenancy
GovOPlaN Tenancy module behavior or integration.
module/views
GovOPlaN governed task views, interface projections, and workflow view integration.
module/workflow
GovOPlaN Workflow module behavior or integration.
module/xoev
GovOPlaN Xoev module behavior or integration.
module/xrechnung
GovOPlaN Xrechnung module behavior or integration.
module/xta-osci
GovOPlaN Xta Osci module behavior or integration.
priority
p0
Immediate stop-the-line priority.
priority
p1
High priority for the next focused work window.
priority
p2
Normal planned priority.
priority
p3
Low priority or opportunistic cleanup.
source/backlog-import
Imported from markdown backlog, roadmap, plan, or TODO files.
source/security-audit
Created from a structured security or code-quality audit report.
source/todo-scan
Imported from inline TODO/FIXME/HACK markers by the Gitea TODO importer.
status
blocked
Cannot progress without a decision, dependency, credential, or external change.
status
in-progress
Currently being worked.
status
needs-info
Needs clarifying input before implementation can proceed safely.
status
ready
Ready for implementation.
status
triage
Needs review, ownership, priority, or acceptance criteria.
type
bug
A reproducible defect, regression, or incorrect behavior.
type
debt
Cleanup, refactoring, risk reduction, or deferred engineering work.
type
docs
Documentation, process, or developer workflow work.
type
feature
New user-visible behavior or platform capability.
type
task
Implementation, maintenance, migration, or operational work.
type
user-story
End-to-end user journey or real-world process story used to steer product slices.
No Label
area/api
area/db
area/security
area/webui
codex/ready
module/dataflow
module/workflow
priority
p1
status
in-progress
type
feature
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
zemion
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: GovOPlaN/govoplan-dataflow#11
No description provided.
Delete Branch "%!s()"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?