aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorjason2017-12-15 15:19:42 -0700
committerjason2017-12-15 15:19:42 -0700
commit5b813d3eb5368831beb1985ddc569c8e7cec8bad (patch)
tree5b93ef363926d1c7ff44f040a6bcf0e2b9231180
parentd79c95c0be755d005927fd940c847e2da23f77d3 (diff)
downloadeventmq-5b813d3eb5368831beb1985ddc569c8e7cec8bad.tar.gz
eventmq-5b813d3eb5368831beb1985ddc569c8e7cec8bad.zip
fix IntervalIter0.3.5.2
-rw-r--r--eventmq/__init__.py2
-rw-r--r--eventmq/utils/timeutils.py12
-rw-r--r--setup.py2
3 files changed, 6 insertions, 10 deletions
diff --git a/eventmq/__init__.py b/eventmq/__init__.py
index a55de23..ac30476 100644
--- a/eventmq/__init__.py
+++ b/eventmq/__init__.py
@@ -1,5 +1,5 @@
1__author__ = 'EventMQ Contributors' 1__author__ = 'EventMQ Contributors'
2__version__ = '0.3.5.1' 2__version__ = '0.3.5.2'
3 3
4PROTOCOL_VERSION = 'eMQP/1.0' 4PROTOCOL_VERSION = 'eMQP/1.0'
5 5
diff --git a/eventmq/utils/timeutils.py b/eventmq/utils/timeutils.py
index 12cf7cc..17a53df 100644
--- a/eventmq/utils/timeutils.py
+++ b/eventmq/utils/timeutils.py
@@ -63,23 +63,19 @@ class IntervalIter(object):
63 next(interval) # 300 63 next(interval) # 300
64 next(interval) # 600 64 next(interval) # 600
65 """ 65 """
66 def __init__(self, start_value, interval_secs, iterate_immediately=False): 66 def __init__(self, start_value, interval_secs):
67 """ 67 """
68 Args: 68 Args:
69 start_value (numeric): the timestamp to begin with. usually gotten 69 start_value (numeric): the timestamp to begin with. usually gotten
70 via :func:`monotonic` or :func:`timestamp` 70 via :func:`monotonic` or :func:`timestamp`
71 interval_secs (int): the number of seconds between intervals 71 interval_secs (int): the number of seconds between intervals
72 iterate_immediately (bool): When this is ``True`` the value of this
73 iterator will increase ``start_value`` by ``interval_secs``
74 immediately. *Default is False*
75 """ 72 """
76 self.current = start_value 73 self.current = start_value
77 self.interval_secs = interval_secs 74 self.interval_secs = interval_secs
78 75
79 # iterate the first time so the first call to .next() is interval_secs 76 # iterate so the first call to .next() is `interval_secs` ahead of the
80 # + start_value 77 # initial `start_value`
81 if iterate_immediately: 78 self.__next__()
82 self.__next__()
83 79
84 def __iter__(self): 80 def __iter__(self):
85 return self 81 return self
diff --git a/setup.py b/setup.py
index e831223..3664ba9 100644
--- a/setup.py
+++ b/setup.py
@@ -7,7 +7,7 @@ from setuptools import find_packages, setup
7 7
8setup( 8setup(
9 name='eventmq', 9 name='eventmq',
10 version='0.3.5.1', 10 version='0.3.5.2',
11 description='EventMQ job execution and messaging system based on ZeroMQ', 11 description='EventMQ job execution and messaging system based on ZeroMQ',
12 packages=find_packages(), 12 packages=find_packages(),
13 install_requires=['pyzmq==15.4.0', 13 install_requires=['pyzmq==15.4.0',