diff options
| author | jason | 2017-12-15 15:19:42 -0700 |
|---|---|---|
| committer | jason | 2017-12-15 15:19:42 -0700 |
| commit | 5b813d3eb5368831beb1985ddc569c8e7cec8bad (patch) | |
| tree | 5b93ef363926d1c7ff44f040a6bcf0e2b9231180 | |
| parent | d79c95c0be755d005927fd940c847e2da23f77d3 (diff) | |
| download | eventmq-5b813d3eb5368831beb1985ddc569c8e7cec8bad.tar.gz eventmq-5b813d3eb5368831beb1985ddc569c8e7cec8bad.zip | |
fix IntervalIter0.3.5.2
| -rw-r--r-- | eventmq/__init__.py | 2 | ||||
| -rw-r--r-- | eventmq/utils/timeutils.py | 12 | ||||
| -rw-r--r-- | setup.py | 2 |
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 | ||
| 4 | PROTOCOL_VERSION = 'eMQP/1.0' | 4 | PROTOCOL_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 |
| @@ -7,7 +7,7 @@ from setuptools import find_packages, setup | |||
| 7 | 7 | ||
| 8 | setup( | 8 | setup( |
| 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', |