File tree 1 file changed +11
-2
lines changed
1 file changed +11
-2
lines changed Original file line number Diff line number Diff line change @@ -58,13 +58,22 @@ run_py_benchmark() {
58
58
ASYNCIO_WAIT=" "
59
59
fi
60
60
61
- CMD_LINE=" UCXPY_ENABLE_DELAYED_SUBMISSION=${ENABLE_DELAYED_SUBMISSION} UCXPY_ENABLE_PYTHON_FUTURE=${ENABLE_PYTHON_FUTURE} timeout 2m python -m ucxx.benchmarks.send_recv --backend ${BACKEND} -o cupy --reuse-alloc -n 8MiB --n-buffers $N_BUFFERS --progress-mode ${PROGRESS_MODE} ${ASYNCIO_WAIT} "
61
+ if [ $PROGRESS_MODE == " thread" ]; then
62
+ # Increased timeout to prevent issues from
63
+ # https://github.com/rapidsai/ucxx/issues/15 .
64
+ # TODO: keep the original 2m timeout when the issue above is resolved.
65
+ TIMEOUT=5m
66
+ else
67
+ TIMEOUT=2m
68
+ fi
69
+
70
+ CMD_LINE=" UCXPY_ENABLE_DELAYED_SUBMISSION=${ENABLE_DELAYED_SUBMISSION} UCXPY_ENABLE_PYTHON_FUTURE=${ENABLE_PYTHON_FUTURE} timeout ${TIMEOUT} python -m ucxx.benchmarks.send_recv --backend ${BACKEND} -o cupy --reuse-alloc -n 8MiB --n-buffers $N_BUFFERS --progress-mode ${PROGRESS_MODE} ${ASYNCIO_WAIT} "
62
71
63
72
rapids-logger " Running: ${CMD_LINE} "
64
73
if [ $SLOW -ne 0 ]; then
65
74
rapids-logger " SLOW BENCHMARK: it may seem like a deadlock but will eventually complete."
66
75
fi
67
- UCXPY_ENABLE_DELAYED_SUBMISSION=${ENABLE_DELAYED_SUBMISSION} UCXPY_ENABLE_PYTHON_FUTURE=${ENABLE_PYTHON_FUTURE} timeout 2m python -m ucxx.benchmarks.send_recv --backend ${BACKEND} -o cupy --reuse-alloc -n 8MiB --n-buffers $N_BUFFERS --progress-mode ${PROGRESS_MODE} ${ASYNCIO_WAIT}
76
+ UCXPY_ENABLE_DELAYED_SUBMISSION=${ENABLE_DELAYED_SUBMISSION} UCXPY_ENABLE_PYTHON_FUTURE=${ENABLE_PYTHON_FUTURE} timeout ${TIMEOUT} python -m ucxx.benchmarks.send_recv --backend ${BACKEND} -o cupy --reuse-alloc -n 8MiB --n-buffers $N_BUFFERS --progress-mode ${PROGRESS_MODE} ${ASYNCIO_WAIT}
68
77
}
69
78
70
79
rapids-logger " Downloading artifacts from previous jobs"
You can’t perform that action at this time.
0 commit comments