diff --git a/synapse/util/task_scheduler.py b/synapse/util/task_scheduler.py index 31922b1ce1..448960b297 100644 --- a/synapse/util/task_scheduler.py +++ b/synapse/util/task_scheduler.py @@ -395,25 +395,25 @@ class TaskScheduler: function = self._actions[task.action] def _occasional_report( - task_log_context: LoggingContext, start_time: int + task_log_context: LoggingContext, start_time: float ) -> None: """ Helper to log a 'Task continuing' line every so often. """ - current_time = int(self._clock.time()) + current_time = self._clock.time() calling_context = set_current_context(task_log_context) try: usage = task_log_context.get_resource_usage() TaskScheduler._log_task_usage( - "continuing", task, usage, (current_time - start_time) * 0.001 + "continuing", task, usage, current_time - start_time ) finally: set_current_context(calling_context) async def wrapper() -> None: with nested_logging_context(task.id) as log_context: - start_time = int(self._clock.time()) + start_time = self._clock.time() occasional_status_call = self._clock.looping_call( _occasional_report, TaskScheduler.OCCASIONAL_REPORT_INTERVAL_MS, @@ -441,10 +441,10 @@ class TaskScheduler: ) self._running_tasks.remove(task.id) - current_time = int(self._clock.time()) + current_time = self._clock.time() usage = log_context.get_resource_usage() TaskScheduler._log_task_usage( - status.value, task, usage, (current_time - start_time) * 0.001 + status.value, task, usage, current_time - start_time ) occasional_status_call.stop()