Commit e9c5ce11 authored by Ignacio's avatar Ignacio
Browse files

.

parent 287dfd55
......@@ -53,7 +53,6 @@ class KubeJobStreamProgress(Plugin):
self.current_job_id = 0
self.job_report = JobReport(info_plugin)
self.report_flag = True
self.last_time_to_complete = -1
self.last_replicas = last_replicas
self.last_error = 0.0
self.last_timestamp = time.time() * 1000
......@@ -181,8 +180,6 @@ class KubeJobStreamProgress(Plugin):
self.LOG.log("========================")
self.LOG.log("Items Completed: %i" % items_completed)
self.LOG.log("Error: %s" % error)
# self.LOG.log("Real-time: %s" % time_to_complete)
self.LOG.log("Expected-time: %s" % self.expected_time)
self.LOG.log("Replicas: %s" % replicas)
self.LOG.log("Queue size: %s" % main_q_size)
self.LOG.log("Pods Processins: %s" % num_processing_jobs)
......@@ -199,7 +196,7 @@ class KubeJobStreamProgress(Plugin):
if self.enable_detailed_report:
job_progress_error = \
self.get_real_time_manifest(time_to_complete,
self.get_real_time_manifest(1,
timestamp)
time_progress_error = \
self.get_expected_time_manifest(self.expected_time,
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment