src/scheduler: schedule a job retry

Get `retry_counter` information from the event
a schedule a job retry.

Signed-off-by: Jeny Sadadia <[email protected]>

Author: Jeny Sadadia

src/scheduler.py

@@ -109,11 +109,11 @@ def _stop(self, sub_id):
             self._api_helper.unsubscribe_filters(sub_id)
         self._cleanup_paths()
 
-    def _run_job(self, job_config, runtime, platform, input_node):
+    def _run_job(self, job_config, runtime, platform, input_node, retry_counter):
         try:
             node = self._api_helper.create_job_node(job_config,
                                                     input_node,
-                                                    runtime, platform)
+                                                    runtime, platform, retry_counter)
         except KeyError as e:
             self.log.error(' '.join([
                 input_node['id'],
@@ -371,7 +371,8 @@ def _run(self, sub_id):
                 if not self._verify_architecture_filter(job, input_node):
                     continue
                 if self._api_helper.should_create_node(rules, input_node):
-                    self._run_job(job, runtime, platform, input_node)
+                    retry_counter = event.get('retry_counter', 0)
+                    self._run_job(job, runtime, platform, input_node, retry_counter)
 
         return True