code: def run(self, timeout=POD_RUN_WAIT_TIMEOUT_SECONDS):
          
  
          if not isinstance(timeout, int):
              raise SyntaxError("K8sCronJob.run() timeout: [ {} ] is invalid.")
  
          if len(self.active):
              raise CronJobAlreadyRunningException(
                  "K8sCronJob.run() failed: CronJob: [ {} ] "
                  "has [ {} ] active Jobs currently.".format(self.name, len(self.active)))
  
          self.suspend = True
          self.update()
  
          pod = self.pod
          if timeout:
              self.POD_RUN_WAIT_TIMEOUT_SECONDS = timeout
  
          try:
              pod.create()
              start_time = time.time()
              while pod.phase not in ['Succeeded', 'Failed']:
                  pod.get()
                  time.sleep(2)
                  self._check_timeout(start_time)
  
          except Exception as err:
              raise CronJobRunException("K8sCronJob.run() failed: {}".format(err))
  
          finally:
              pod.delete()
              self.suspend = False
              self.update()
docs: Forces a K8sCronJob to run immediately.
  
          - Fail if the K8sCronJob is currently running on-schedule.
          - Suspend the K8sCronJob.
          - Spawn a K8sPod.
          - Unsuspend a K8sCronJob.
  
          :param timeout: The timeout, in seconds, after which to kill the K8sPod.
  
          :return: None.