OPT project structure

This commit is contained in:
Peter 2025-12-29 16:46:41 +01:00
parent ec0483c409
commit 5c4dc8a630
5 changed files with 9 additions and 1127 deletions

File diff suppressed because it is too large Load Diff

View File

@ -27,18 +27,5 @@ schiphol = "src.main:main"
requires = ["setuptools>=61.0"]
build-backend = "setuptools.build_meta"
[tool.setuptools.packages.find]
where = ["."]
include = ["src*"]
[tool.ruff]
line-length = 100
target-version = "py314"
[tool.ruff.lint]
select = ["E", "F", "I", "UP", "B", "SIM"]
ignore = []
[tool.ruff.format]
quote-style = "double"
indent-style = "space"
[tool.setuptools]
packages = ["src"]

View File

@ -0,0 +1 @@
"""Schiphol flight data producer."""

View File

@ -47,7 +47,9 @@ async def start():
total_flights = 0
while next_url:
with tracer.start_as_current_span("fetch_page", attributes={"http.url": next_url}):
with tracer.start_as_current_span(
"fetch_page", attributes={"http.url": next_url}
):
response = session.get(next_url)
response.raise_for_status()
data = response.json()
@ -80,7 +82,9 @@ async def start():
next_url = link.split(";")[0].strip().strip("<>")
break
logger.info(f"Published {total_flights} flights to Kafka topic '{kafka_settings.topic}'")
logger.info(
f"Published {total_flights} flights to Kafka topic '{kafka_settings.topic}'"
)
await stream_engine.stop()