Skip to content

Commit

Permalink
increment seconds
Browse files Browse the repository at this point in the history
  • Loading branch information
Cristian Goina committed Apr 29, 2021
1 parent 04fc351 commit 3d0ff08
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions lib/processes.nf
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@ process wait_for_path {
sleep \${SLEEP_SECS}
if (( \${SECONDS} < \${MAX_WAIT_SECS} )); then
echo "Waiting for $f"
SECONDS=\$(( \${SECONDS} + \${SLEEP_SECS} ))
else
echo "Timed out after \${SECONDS} seconds while waiting for $f"
exit 1
Expand Down Expand Up @@ -145,6 +146,8 @@ process wait_for_master {
fi
sleep \${SLEEP_SECS}
SECONDS=\$(( \${SECONDS} + \${SLEEP_SECS} ))
done
spark_uri=\${test_uri}
Expand Down Expand Up @@ -264,7 +267,8 @@ process wait_for_worker {
exit 2
fi
sleep 1
sleep \${SLEEP_SECS}
SECONDS=\$(( \${SECONDS} + \${SLEEP_SECS} ))
done
"""
Expand Down Expand Up @@ -501,7 +505,7 @@ def lookup_ip_inside_docker_script() {

def wait_to_terminate(pid_var, terminate_file_name) {
"""
trap "echo kill \$${pid_var} && kill \$${pid_var}" EXIT
trap "kill \$${pid_var}" EXIT
while true; do
Expand Down

0 comments on commit 3d0ff08

Please sign in to comment.