Skip to content

Commit 8de5c72

Browse files
more debug
1 parent fc316de commit 8de5c72

File tree

2 files changed

+7
-6
lines changed

2 files changed

+7
-6
lines changed

cads_broker/database.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -527,12 +527,14 @@ def user_last_completed_request(
527527
user_uid, max_time_datetime
528528
)
529529

530-
return int(
530+
value = int(
531531
(
532532
datetime.datetime.now()
533533
- max(user_last_finished_at_datetime, max_time_datetime)
534534
).total_seconds()
535535
)
536+
print("FINISHED AT", value)
537+
return value
536538

537539

538540
def user_resource_used(
@@ -552,6 +554,7 @@ def user_resource_used(
552554
)
553555
QOS_FUNCTIONS_CACHE["users_resources"] = users_resources
554556

557+
print("--------RESOURCE", users_resources.get(user_uid, 0))
555558
return users_resources.get(user_uid, 0)
556559

557560

cads_broker/qos/QoS.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -180,11 +180,9 @@ def dynamic_priority(self, request):
180180
def priority(self, request):
181181
"""Compute the priority of a request."""
182182
# The priority of a request increases with time
183-
starting_priority = self._properties(request).starting_priority
184-
dynamic_priority = self.dynamic_priority(request)
185-
print("starting priority: ", starting_priority)
186-
print("dynamic priority: ", dynamic_priority)
187-
return starting_priority + dynamic_priority
183+
return self._properties(
184+
request
185+
).starting_priority + self.dynamic_priority(request)
188186

189187
def dump(self, out=print):
190188
self.rules.dump(out)

0 commit comments

Comments
 (0)