Write run_at in a resque-compatible format

toby cabot · toby cabot · commit cdc0a4fedd0e · 2016-11-17T16:57:18.000-05:00
Resque expects that the run_at value will be an ISO8601 string in UTC.
Pyres was writing seconds since the epoch, which caused pyres-web to
crash.
diff --git a/pyres/horde.py b/pyres/horde.py
@@ -109,7 +109,7 @@ def working_on(self, job):
         self.logger.debug('marking as working on')
         data = {
             'queue': job._queue,
-            'run_at': int(time.mktime(datetime.datetime.now().timetuple())),
+            'run_at': datetime.datetime.utcnow().isoformat() + "Z",
             'payload': job._payload
         }
         data = json.dumps(data)
diff --git a/pyres/worker.py b/pyres/worker.py
@@ -285,7 +285,7 @@ def working_on(self, job):
         logger.debug('marking as working on')
         data = {
             'queue': job._queue,
-            'run_at': str(int(time.mktime(datetime.datetime.now().timetuple()))),
+            'run_at': datetime.datetime.utcnow().isoformat() + "Z",
             'payload': job._payload
         }
         data = json.dumps(data)

Original file line number	Diff line number	Diff line change
`@@ -109,7 +109,7 @@ def working_on(self, job):`
`109`	`109`	`self.logger.debug('marking as working on')`
`110`	`110`	`data = {`
`111`	`111`	`'queue': job._queue,`
`112`		`- 'run_at': int(time.mktime(datetime.datetime.now().timetuple())),`
	`112`	`+ 'run_at': datetime.datetime.utcnow().isoformat() + "Z",`
`113`	`113`	`'payload': job._payload`
`114`	`114`	`}`
`115`	`115`	`data = json.dumps(data)`
Original file line number	Diff line number	Diff line change
`@@ -285,7 +285,7 @@ def working_on(self, job):`
`285`	`285`	`logger.debug('marking as working on')`
`286`	`286`	`data = {`
`287`	`287`	`'queue': job._queue,`
`288`		`- 'run_at': str(int(time.mktime(datetime.datetime.now().timetuple()))),`
	`288`	`+ 'run_at': datetime.datetime.utcnow().isoformat() + "Z",`
`289`	`289`	`'payload': job._payload`
`290`	`290`	`}`
`291`	`291`	`data = json.dumps(data)`