Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
449341e
add CPS flow & viz update
LOCEANlloydizard Jul 3, 2026
b617c00
Add transect update monitoring flow
LOCEANlloydizard Aug 12, 2026
69be9e0
Refactor reusable transect helpers
LOCEANlloydizard Aug 12, 2026
348c5b4
WIP restore CPS changes
LOCEANlloydizard Aug 14, 2026
02e9153
Merge branch 'monitor-transect-updates' into add-cps-flow
LOCEANlloydizard Aug 14, 2026
f40556a
Merge branch 'add-transect-simulation' into add-cps-flow
LOCEANlloydizard Aug 14, 2026
cd6e821
Merge branch 'monitor-transect-updates' into add-cps-flow
LOCEANlloydizard Aug 14, 2026
fb667ce
Merge remote-tracking branch 'upstream/main' into add-cps-flow
LOCEANlloydizard Aug 14, 2026
60a3159
Add SQLite processing ledger for realtime workflows
LOCEANlloydizard Aug 15, 2026
b76970d
Merge branch 'watchdog-file-ledger' into add-cps-flow
LOCEANlloydizard Aug 15, 2026
147d409
Improve realtime file watcher reconciliation
LOCEANlloydizard Aug 16, 2026
a72e5a6
Merge branch 'watchdog-file-ledger' into add-cps-flow
LOCEANlloydizard Aug 16, 2026
60a7ff2
Complete CPS near-real-time workflow
LOCEANlloydizard Aug 18, 2026
aaca653
dd SQLAlchemy and postgreSQL support
LOCEANlloydizard Aug 20, 2026
54fafdd
Merge branch 'watchdog-file-ledger' into add-cps-flow
LOCEANlloydizard Aug 20, 2026
349de89
Support PostgreSQL in CPS flow and monitor
LOCEANlloydizard Aug 20, 2026
b300bab
Merge branch 'main' into add-cps-flow
LOCEANlloydizard Aug 20, 2026
fcd911b
handle empty transect CSV after watchdog merge
LOCEANlloydizard Aug 20, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ dynamic = ["version"]
mission = [
"echopype",
"echoshader",
"echoregions",
"opencv",
]
notebook = [
Expand Down
17 changes: 16 additions & 1 deletion src/echodataflow/deployment/flow_registry.py
Original file line number Diff line number Diff line change
Expand Up @@ -69,8 +69,23 @@ class FlowRegistration:
"update_cache_MVBS": FlowRegistration(
entrypoint="echodataflow/flows/flows_viz_cloud.py:flow_update_cache_MVBS",
),
"update_cache_CPS": FlowRegistration(
entrypoint="echodataflow/flows/flows_viz_cloud.py:flow_update_cache_CPS",
description="Update the visualization cache from the latest CPS plot product.",
),
"transect_update": FlowRegistration(
entrypoint="echodataflow/flows/flows_transect.py:flow_transect_update",
description="Process updates to transect start/end information.",
),
}
"process_CPS": FlowRegistration(
entrypoint="echodataflow/flows/flows_CPS.py:flow_process_CPS",
description="Process CPS acoustic data for new or updated transect segments.",
),
"simulate_transects": FlowRegistration(
entrypoint=(
"echodataflow/flows/flows_simulation.py:"
"flow_simulate_transects"
),
description="Simulate realtime transect updates for testing.",
),
}
Loading