Skip to content

Commit

Permalink
Fix task deprecation endpoint
Browse files Browse the repository at this point in the history
  • Loading branch information
munrojm committed Jun 1, 2021
1 parent 045f3ad commit 0c5c4af
Showing 1 changed file with 18 additions and 4 deletions.
22 changes: 18 additions & 4 deletions src/mp_api/routes/tasks/query_operators.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,10 @@ class MultipleTaskIDsQuery(QueryOperator):
"""

def query(
self, task_ids: Optional[str] = Query(None, description="Comma-separated list of task_ids to query on"),
self,
task_ids: Optional[str] = Query(
None, description="Comma-separated list of task_ids to query on"
),
) -> STORE_PARAMS:

crit = {}
Expand All @@ -29,7 +32,10 @@ class TrajectoryQuery(QueryOperator):
"""

def query(
self, task_ids: Optional[str] = Query(None, description="Comma-separated list of task_ids to query on"),
self,
task_ids: Optional[str] = Query(
None, description="Comma-separated list of task_ids to query on"
),
) -> STORE_PARAMS:

crit = {}
Expand All @@ -45,7 +51,12 @@ def post_process(self, docs):
"""

d = [
{"task_id": doc["task_id"], "trajectories": jsanitize(calcs_reversed_to_trajectory(doc["calcs_reversed"])),}
{
"task_id": doc["task_id"],
"trajectories": jsanitize(
calcs_reversed_to_trajectory(doc["calcs_reversed"])
),
}
for doc in docs
]

Expand All @@ -58,7 +69,10 @@ class DeprecationQuery(QueryOperator):
"""

def query(
self, task_ids: str = Query(None, description="Comma-separated list of task_ids to query on"),
self,
task_ids: str = Query(
..., description="Comma-separated list of task_ids to query on"
),
) -> STORE_PARAMS:

self.task_ids = task_ids.split(",")
Expand Down

0 comments on commit 0c5c4af

Please sign in to comment.