Merge branch 'main' into feat/search_endpoint_features

Author: davidgamez

functions-python/helpers/query_helper.py

@@ -10,7 +10,7 @@
     Gtfsdataset,
     Validationreport,
 )
-from sqlalchemy import and_, or_
+from sqlalchemy import and_
 from sqlalchemy.orm import Session, joinedload
 from sqlalchemy.orm.query import Query
 
@@ -160,7 +160,7 @@ def get_datasets_with_missing_reports_query(
         .select_from(Gtfsfeed)
         .join(Gtfsdataset, Gtfsdataset.feed_id == Gtfsfeed.id)
         .outerjoin(Validationreport, Gtfsdataset.validation_reports)
-        .filter(or_(Validationreport.id.is_(None)))
+        .filter(Validationreport.id.is_(None))
     )
     if filter_after:
         query = query.filter(Gtfsdataset.downloaded_at >= filter_after)

functions-python/tasks_executor/src/main.py

@@ -54,12 +54,12 @@ def get_task(request: flask.Request):
     """
     request_json = request.get_json(silent=True)
     if not request_json:
-        raise ValueError("Invalid JSON payload")
+        raise ValueError("Invalid JSON request")
     if not request_json.get("task"):
         raise ValueError("Task not provided")
     task = request_json.get("task")
     if task not in tasks:
-        raise ValueError("Task not supported")
+        raise ValueError("Task not supported: %s", task)
     payload = request_json.get("payload")
     if not payload:
         payload = {}