Skip to content

Commit beca3e9

Browse files
committed
measurement_flow_process_duration is set in any case. Supplying a timeout of None will lead to no timeout
1 parent 164e3a3 commit beca3e9

File tree

1 file changed

+9
-16
lines changed

1 file changed

+9
-16
lines changed

lib/scenario_runner.py

Lines changed: 9 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1485,22 +1485,15 @@ def run_flows(self):
14851485
print('Executing process synchronously.')
14861486
if self._measurement_flow_process_duration:
14871487
print(f"Alloting {self._measurement_flow_process_duration}s runtime ...")
1488-
ps = subprocess.run(
1489-
docker_exec_command,
1490-
stderr=stderr_behaviour,
1491-
stdout=stdout_behaviour,
1492-
encoding='UTF-8',
1493-
check=False, # cause it will be checked later and also ignore-errors checked
1494-
timeout=self._measurement_flow_process_duration,
1495-
)
1496-
else:
1497-
ps = subprocess.run(
1498-
docker_exec_command,
1499-
stderr=stderr_behaviour,
1500-
stdout=stdout_behaviour,
1501-
encoding='UTF-8',
1502-
check=False, # cause it will be checked later and also ignore-errors checked
1503-
)
1488+
1489+
ps = subprocess.run(
1490+
docker_exec_command,
1491+
stderr=stderr_behaviour,
1492+
stdout=stdout_behaviour,
1493+
encoding='UTF-8',
1494+
check=False, # cause it will be checked later and also ignore-errors checked
1495+
timeout=self._measurement_flow_process_duration,
1496+
)
15041497

15051498
ps_to_read_tmp.append({
15061499
'cmd': docker_exec_command,

0 commit comments

Comments
 (0)