Add "nohaste" header for scheduled jobs

What
===

1.  Add the `haste` option (header) for scheduling jobs.
This will allow you to schedule a job, and either have it run as it's
scheduled, or wait until the interval has elapsed.

Why
===

1.  We need it for the debounce decorator, among other things

Tests
=====

I tried it manually

2 files changed, 10 insertions, 11 deletions

diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index f25f98c..1a6d7c6 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -161,9 +161,9 @@ class JobManager(HeartbeatMixin, EMQPService):
         params = payload[1]
 
         if 'reply-requested' in headers:
-           callback = self.worker_done_with_reply
+            callback = self.worker_done_with_reply
         else:
-           callback = self.worker_done
+            callback = self.worker_done
 
         # kick off the job asynchronously with an appropiate callback
         self.workers.apply_async(func=worker.run,
@@ -185,7 +185,7 @@ class JobManager(HeartbeatMixin, EMQPService):
         sendmsg(self.outgoing, 'READY')
 
     def send_reply(self, res):
-         """
+        """
          Sends an REPLY response
 
          Args:
@@ -193,12 +193,10 @@ class JobManager(HeartbeatMixin, EMQPService):
              recipient (str): The recipient id for the ack
              msgid: The unique id that we are acknowledging
          """
-         msgid = res[0]
-
-         reply = res[1]
-
-         reply = serializer(reply)
-         sendmsg(self.outgoing, 'REPLY', [reply, msgid])
+        msgid = res[0]
+        reply = res[1]
+        reply = serializer(reply)
+        sendmsg(self.outgoing, 'REPLY', [reply, msgid])
 
     def on_heartbeat(self, msgid, message):
         """
diff --git a/eventmq/scheduler.py b/eventmq/scheduler.py
index 7538fdd..7bf2dba 100644
--- a/eventmq/scheduler.py
+++ b/eventmq/scheduler.py
@@ -17,7 +17,6 @@
 =============================
 Handles cron and other scheduled tasks
 """
-import sys
 import json
 import logging
 import redis
@@ -298,6 +297,7 @@ class Scheduler(HeartbeatMixin, EMQPService):
         logger.info("Received new SCHEDULE request: {}".format(message))
 
         queue = message[0]
+        headers = message[1]
         interval = int(message[2])
         cron = str(message[4])
 
@@ -354,7 +354,8 @@ class Scheduler(HeartbeatMixin, EMQPService):
         except Exception as e:
             logger.warning(str(e))
 
-        self.send_request(message[3], queue=queue)
+        if 'dont_start_immediately' not in headers:
+            self.send_request(message[3], queue=queue)
 
     def on_heartbeat(self, msgid, message):
         """