Skip to content

Commit 18bc81b

Browse files
committed
fix edge case with onboarding
1 parent 6362811 commit 18bc81b

File tree

2 files changed

+51
-9
lines changed

2 files changed

+51
-9
lines changed

src/tasks/data.py

Lines changed: 16 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -75,16 +75,23 @@ def summary_activity_to_activity_model(summary_activity: SummaryActivity) -> Act
7575
activity_dict["pace_min_per_km"] = None
7676

7777
decoded = polyline.decode(activity_dict["map"]["summary_polyline"])
78-
if len(decoded) > 0:
79-
poly = Polygon(decoded)
80-
centroid = poly.centroid
81-
centroid_lat = centroid.x
82-
centroid_lon = centroid.y
83-
area = poly.area
8478

85-
activity_dict["map_centroid_lat"] = centroid_lat
86-
activity_dict["map_centroid_lon"] = centroid_lon
87-
activity_dict["map_area"] = area
79+
if len(decoded) > 0:
80+
try:
81+
poly = Polygon(decoded)
82+
centroid = poly.centroid
83+
centroid_lat = centroid.x
84+
centroid_lon = centroid.y
85+
area = poly.area
86+
87+
activity_dict["map_centroid_lat"] = centroid_lat
88+
activity_dict["map_centroid_lon"] = centroid_lon
89+
activity_dict["map_area"] = area
90+
except Exception as e:
91+
print(f"Error processing polyline: {e}")
92+
activity_dict["map_centroid_lat"] = None
93+
activity_dict["map_centroid_lon"] = None
94+
activity_dict["map_area"] = None
8895

8996
activity_dict["map_summary_polyline"] = activity_dict["map"]["summary_polyline"]
9097

src/tasks/manual_onboard.py

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
import logging
2+
import datetime
3+
from typing import Annotated
4+
5+
from fastapi import APIRouter, BackgroundTasks, Query, Request, HTTPException
6+
from fastapi.responses import RedirectResponse
7+
from fastapi.templating import Jinja2Templates
8+
from dotenv import load_dotenv
9+
10+
from src.app.routes.authorization import AUTHORIZATION_CALLBACK
11+
from src.app.schemas.login_request import LoginRequest
12+
from src.app.config import settings
13+
from src.tasks.etl import AuthETL, UserETL, ActivitiesETL
14+
15+
from src.database.adapter import Database
16+
from src.tasks.telegram import TelegramBot
17+
18+
19+
load_dotenv(override=True)
20+
21+
logger = logging.getLogger(__name__)
22+
23+
auth_uuid="XXXX-XXXX-XXXX-XXXX" # Replace with the actual auth_uuid
24+
25+
days = 365 * 3
26+
# days = 365 * 5
27+
before: datetime.datetime = datetime.datetime.now()
28+
after: datetime.datetime = before - datetime.timedelta(days=days)
29+
activities_etl = ActivitiesETL(
30+
auth_uuid=auth_uuid,
31+
settings=settings,
32+
after=after,
33+
before=before,
34+
)
35+
activities_etl.run()

0 commit comments

Comments
 (0)