in azure/datalake/store/transfer.py [0:0]
def _wait(self, poll=0.1, timeout=0):
start = time.time()
while self.active:
if timeout > 0 and time.time() - start > timeout:
break
time.sleep(poll)