Update docstring for Worker class

joowani · May 10, 2017 · f722688 · f722688
1 parent 5cc18b8
commit f722688
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kq/worker.py b/kq/worker.py
@@ -34,6 +34,7 @@ class Worker(object):
             keyfile='/my/files/keyfile',
             crlfile='/my/files/crlfile',
             proc_ttl=2000,
+            offset_policy='earliest'
         )
         worker.start()
 
@@ -96,7 +97,7 @@ class Worker(object):
     :type proc_ttl: int
     :param offset_policy: Policy for resetting offsets on the Kafka consumer.
         Value ``"earliest"`` moves the offset to the oldest available message
-        and ``"latest"`` to the most recent. Default: 'latest'.
+        and ``"latest"`` to the most recent. Default: ``"latest"``.
     :type offset_policy: str | unicode
     """