Fix

Signed-off-by: Tyler Gu <[email protected]>

performance_measurement/measure_runner.py

@@ -309,7 +309,7 @@ def run(self,
                         continue
 
                 if condition_2 is None:
-                    if (ds_event["object"].status.number_ready == input["spec"]["replicas"]
+                    if (ds_event["object"].status.number_ready == ds_event["object"].status.desired_number_scheduled
                             and current_spec_hash == last_spec_hash):
                         condition_2 = timestamp
                         break
@@ -872,6 +872,7 @@ def watch_system_events(event_stream, queue: Queue):
         '''
         for object in event_stream:
             try:
+                logging.info("Event: %s %s" % (object['type'], object['object'].metadata.name))
                 ts = time.time()
                 queue.put((object, ts))
             except (ValueError, AssertionError):