Commit 7868781d authored by Ignacio's avatar Ignacio
Browse files

updating stuff

parent de351844
......@@ -240,7 +240,6 @@ class KubeJobStreamProgress(Plugin):
self.get_parallelism_manifest(replicas, timestamp)
self.publish_persistent_measurement(application_progress_error,
job_progress_error,
time_progress_error,
parallelism,
input_flux,
......@@ -252,7 +251,6 @@ class KubeJobStreamProgress(Plugin):
def publish_persistent_measurement(self, application_progress_error,
job_progress_error,
time_progress_error,
parallelism,
input_flux,
......@@ -260,7 +258,6 @@ class KubeJobStreamProgress(Plugin):
expected_output_flux):
self.datasource.send_metrics([application_progress_error])
self.datasource.send_metrics([job_progress_error])
self.datasource.send_metrics([time_progress_error])
self.datasource.send_metrics([parallelism])
self.datasource.send_metrics([input_flux])
......@@ -300,9 +297,9 @@ class KubeJobStreamProgress(Plugin):
def monitoring_application(self):
try:
job_progress = self.rds.llen('job:results')
self._publish_measurement(items_completed=job_progress)
return job_progress
items_completed = self.rds.llen('job:results')
self._publish_measurement(items_completed=items_completed)
return items_completed
except Exception as ex:
self.LOG.log(ex.message)
self.LOG.log(("Error: No application found for %s.\
......
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