Schiphol flight data Kafka producer/consumer pipeline
- Add pytest and pytest-asyncio as optional dev dependencies - Configure asyncio_mode=auto and pythonpath=[src] in pyproject.toml - Write three tests at the poll() seam: * single-page response publishes all Flights and returns the count * paginated response follows link:rel=next and publishes all pages * HTTP error from raise_for_status() propagates out of poll() Tests use injected stub HTTP session and mock Kafka engine; no real network or broker required. Closes #4 Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> |
||
|---|---|---|
| .gitea/workflows | ||
| src | ||
| tests | ||
| tools | ||
| .envrc | ||
| .gitignore | ||
| .python-version | ||
| pyproject.toml | ||
| README.md | ||
| sonar-project.properties | ||
| uv.lock | ||
schiphol
Example event-based python application