Skip to content

Commit d7edf5d

Browse files
authored
Polling fix (#149)
1 parent 8e0c06e commit d7edf5d

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

railib/__init__.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,5 +12,5 @@
1212
# See the License for the specific language governing permissions and
1313
# limitations under the License.
1414

15-
__version_info__ = (0, 7, 2)
15+
__version_info__ = (0, 7, 3)
1616
__version__ = ".".join(map(str, __version_info__))

railib/api.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -324,11 +324,13 @@ def _parse_arrow_results(files: List[TransactionAsyncFile]):
324324
def poll_with_specified_overhead(
325325
f,
326326
overhead_rate: float,
327-
start_time: int = time.time(),
327+
start_time: float = None,
328328
timeout: int = None,
329329
max_tries: int = None,
330330
max_delay: int = 120,
331331
):
332+
if start_time is None:
333+
start_time = time.time()
332334
tries = 0
333335
max_time = time.time() + timeout if timeout else None
334336

0 commit comments

Comments
 (0)