diff --git a/src/py/flwr/server/superlink/state/sqlite_state.py b/src/py/flwr/server/superlink/state/sqlite_state.py index 1c112285f489..f4f26095aa9d 100644 --- a/src/py/flwr/server/superlink/state/sqlite_state.py +++ b/src/py/flwr/server/superlink/state/sqlite_state.py @@ -280,6 +280,9 @@ def get_task_ins( raise AssertionError(msg) data: Dict[str, Union[str, int]] = {} + # Convert a uint64 value to sint64 for SQLite + sint64_node_id = uint64_to_sint64(node_id) + data["node_id"] = sint64_node_id if node_id is None: # Retrieve all anonymous Tasks @@ -300,10 +303,6 @@ def get_task_ins( AND delivered_at = "" """ - # Convert a uint64 value to sint64 for SQLite - sint64_node_id = uint64_to_sint64(node_id) - data["node_id"] = sint64_node_id - if limit is not None: query += " LIMIT :limit" data["limit"] = limit