Merge 94a7798 into 43c9279

rq/decorators.py

@@ -44,8 +44,9 @@ def delay(*args, **kwargs):
             else:
                 queue = self.queue
             depends_on = kwargs.pop('depends_on', None)
+            meta = kwargs.pop('meta', None)
             return queue.enqueue_call(f, args=args, kwargs=kwargs,
                                       timeout=self.timeout, result_ttl=self.result_ttl,
-                                      ttl=self.ttl, depends_on=depends_on)
+                                      ttl=self.ttl, depends_on=depends_on, meta=meta)
         f.delay = delay
         return f

tests/test_decorator.py

@@ -92,6 +92,23 @@ def bar():
 
         self.assertEqual(bar_job._dependency_id, foo_job.id)
 
+    def test_decorator_accepts_metaas_argument(self):
+        """Ensure that passing in meta to the decorator sets the
+        meta on the job correctly.
+        """
+
+        @job(queue='queue_name')
+        def hello():
+            return 'Hello'
+
+        test_meta = {
+            'metaKey1': 1,
+            'metaKey2': 2,
+        }
+
+        result = hello.delay(meta=test_meta)
+        self.assertEqual(result.meta, test_meta)
+
     @mock.patch('rq.queue.resolve_connection')
     def test_decorator_connection_laziness(self, resolve_connection):
         """Ensure that job decorator resolve connection in `lazy` way """