peter/schiphol
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

OPT add linting workflow

Browse Source
This commit is contained in:
Peter 2025-12-29 17:00:39 +01:00
parent 1238264f74
commit ff5c8ba548
2 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pyproject.toml
View File

@ -27,8 +27,9 @@ schiphol = "src.main:main"
requires = ["setuptools>=61.0"] requires = ["setuptools>=61.0"]
build-backend = "setuptools.build_meta" build-backend = "setuptools.build_meta"
[tool.setuptools] [tool.setuptools.packages.find]
packages = ["src"] where = ["."]
include = ["src*"]
[tool.ruff] [tool.ruff]
line-length = 100 line-length = 100

8
src/main.py
View File

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