Skip to content

Commit 53cbdc6

Browse files
committed
update placement time of pushed placement
1 parent 25f4a3d commit 53cbdc6

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

simulator.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -341,7 +341,7 @@ def event_representation_filter(record):
341341
self.__log_utilization(self._simulator_time)
342342

343343
# Internal data.
344-
self._last_scheduler_start_time = self._simulator_time
344+
self._last_scheduler_start_time = EventTime.invalid()
345345
self._next_scheduler_event = None
346346
self._last_scheduler_placements: Optional[Placements] = None
347347

@@ -582,6 +582,10 @@ def __handle_scheduler_start(self, event: Event) -> None:
582582
Args:
583583
event (`Event`): The event to handle.
584584
"""
585+
586+
if self._last_scheduler_start_time == event.time:
587+
return
588+
585589
# Log the required CSV information.
586590
currently_placed_tasks = self._worker_pools.get_placed_tasks()
587591
schedulable_tasks = self._workload.get_schedulable_tasks(
@@ -1430,6 +1434,7 @@ def __handle_task_placement(self, event: Event, workload: Workload) -> None:
14301434
task=event.task,
14311435
placement=event.placement,
14321436
)
1437+
event.placement._placement_time = next_placement_time
14331438
self._future_placement_events[task.id] = next_placement_event
14341439
self._event_queue.add_event(next_placement_event)
14351440
self._logger.info(

0 commit comments

Comments
 (0)