peter/schiphol
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity
Schiphol flight data Kafka producer/consumer pipeline
12 Commits 4 Branches 0 Tags 102 KiB
Python 100%
68734dee3e
Go to file
Peter 68734dee3e feat: implement continuous polling loop 
start() now loops indefinitely, calling poll() every 5 minutes.
Each cycle is wrapped in a poll_cycle OTel span with a
flights.published attribute (0 on failure). Transient poll failures
are logged and the loop continues. The Kafka stream engine is stopped
cleanly via try/finally on shutdown.

Closes #5

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
2026-07-19 09:11:07 +02:00
.gitea/workflows OPT add linting workflow 2025-12-29 17:00:39 +01:00
src feat: implement continuous polling loop 2026-07-19 09:11:07 +02:00
tests test: add pytest infrastructure and poll() tests 2026-07-19 09:07:27 +02:00
tools OPT project structure 2025-12-29 17:15:29 +01:00
.env NEW: initial commit 2025-12-28 16:09:27 +01:00
.envrc NEW: initial commit 2025-12-28 16:09:27 +01:00
.gitignore NEW: initial commit 2025-12-28 16:09:27 +01:00
.python-version NEW: initial commit 2025-12-28 16:09:27 +01:00
pyproject.toml test: add pytest infrastructure and poll() tests 2026-07-19 09:07:27 +02:00
README.md NEW: initial commit 2025-12-28 16:09:27 +01:00
sonar-project.properties Merge remote-tracking branch 'origin/main' into new/initial_commit 2025-12-28 18:36:07 +01:00
uv.lock NEW: initial commit 2025-12-28 16:09:27 +01:00

README.md

schiphol

Example event-based python application