examples/python/comm-waitallfor/comm-waitallfor.tesh

   1 #!/usr/bin/env tesh
   2
   3 p Testing Comm.wait_all_for()
   4
   5 $ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 1 --wait-timeout 1 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
   6 >[  0.000000] (2:worker@Ruby) worker-0 started
   7 >[  0.000000] (1:client@Tremblay) client started
   8 >[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=1.0s)
   9 >[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
  10 >[  1.000000] (1:client@Tremblay) received 0/5 results
  11 >[  1.000000] (1:client@Tremblay) job-0 status=pending result_payload=
  12 >[  1.000000] (1:client@Tremblay) job-1 status=pending result_payload=
  13 >[  1.000000] (1:client@Tremblay) job-2 status=pending result_payload=
  14 >[  1.000000] (1:client@Tremblay) job-3 status=pending result_payload=
  15 >[  1.000000] (1:client@Tremblay) job-4 status=pending result_payload=
  16
  17 $ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 1 --wait-timeout 5 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
  18 >[  0.000000] (2:worker@Ruby) worker-0 started
  19 >[  0.000000] (1:client@Tremblay) client started
  20 >[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=5.0s)
  21 >[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
  22 >[  1.008029] (2:worker@Ruby) worker-0 working on job-1 (will take 2.0s to complete)
  23 >[  3.014105] (2:worker@Ruby) worker-0 working on job-2 (will take 3.0s to complete)
  24 >[  5.000000] (1:client@Tremblay) received 2/5 results
  25 >[  5.000000] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
  26 >[  5.000000] (1:client@Tremblay) job-1 status=complete result_payload=worker-0
  27 >[  5.000000] (1:client@Tremblay) job-2 status=pending result_payload=
  28 >[  5.000000] (1:client@Tremblay) job-3 status=pending result_payload=
  29 >[  5.000000] (1:client@Tremblay) job-4 status=pending result_payload=
  30
  31 $ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 1 --wait-timeout -1 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
  32 >[  0.000000] (2:worker@Ruby) worker-0 started
  33 >[  0.000000] (1:client@Tremblay) client started
  34 >[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=-1.0s)
  35 >[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
  36 >[  1.008029] (2:worker@Ruby) worker-0 working on job-1 (will take 2.0s to complete)
  37 >[  3.014105] (2:worker@Ruby) worker-0 working on job-2 (will take 3.0s to complete)
  38 >[  6.020181] (2:worker@Ruby) worker-0 working on job-3 (will take 4.0s to complete)
  39 >[ 10.026257] (2:worker@Ruby) worker-0 working on job-4 (will take 5.0s to complete)
  40 >[ 15.030379] (1:client@Tremblay) received 5/5 results
  41 >[ 15.030379] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
  42 >[ 15.030379] (1:client@Tremblay) job-1 status=complete result_payload=worker-0
  43 >[ 15.030379] (1:client@Tremblay) job-2 status=complete result_payload=worker-0
  44 >[ 15.030379] (1:client@Tremblay) job-3 status=complete result_payload=worker-0
  45 >[ 15.030379] (1:client@Tremblay) job-4 status=complete result_payload=worker-0
  46
  47 $ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 5 --wait-timeout 3 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
  48 >[  0.000000] (2:worker@Ruby) worker-0 started
  49 >[  0.000000] (3:worker@Ruby) worker-1 started
  50 >[  0.000000] (4:worker@Ruby) worker-2 started
  51 >[  0.000000] (5:worker@Ruby) worker-3 started
  52 >[  0.000000] (6:worker@Ruby) worker-4 started
  53 >[  0.000000] (1:client@Tremblay) client started
  54 >[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=3.0s)
  55 >[  0.001954] (6:worker@Ruby) worker-4 working on job-4 (will take 5.0s to complete)
  56 >[  0.001954] (5:worker@Ruby) worker-3 working on job-3 (will take 4.0s to complete)
  57 >[  0.001954] (4:worker@Ruby) worker-2 working on job-2 (will take 3.0s to complete)
  58 >[  0.001954] (3:worker@Ruby) worker-1 working on job-1 (will take 2.0s to complete)
  59 >[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
  60 >[  3.000000] (1:client@Tremblay) received 2/5 results
  61 >[  3.000000] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
  62 >[  3.000000] (1:client@Tremblay) job-1 status=complete result_payload=worker-1
  63 >[  3.000000] (1:client@Tremblay) job-2 status=pending result_payload=
  64 >[  3.000000] (1:client@Tremblay) job-3 status=pending result_payload=
  65 >[  3.000000] (1:client@Tremblay) job-4 status=pending result_payload=
  66
  67 $ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 5 --wait-timeout -1 --jobs 5,10,5,20,5,40,5,80,5,160 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
  68 >[  0.000000] (2:worker@Ruby) worker-0 started
  69 >[  0.000000] (3:worker@Ruby) worker-1 started
  70 >[  0.000000] (4:worker@Ruby) worker-2 started
  71 >[  0.000000] (5:worker@Ruby) worker-3 started
  72 >[  0.000000] (6:worker@Ruby) worker-4 started
  73 >[  0.000000] (1:client@Tremblay) client started
  74 >[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=-1.0s)
  75 >[  0.001954] (6:worker@Ruby) worker-4 working on job-4 (will take 5.0s to complete)
  76 >[  0.001954] (5:worker@Ruby) worker-3 working on job-3 (will take 20.0s to complete)
  77 >[  0.001954] (4:worker@Ruby) worker-2 working on job-2 (will take 5.0s to complete)
  78 >[  0.001954] (3:worker@Ruby) worker-1 working on job-1 (will take 10.0s to complete)
  79 >[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 5.0s to complete)
  80 >[  5.008029] (2:worker@Ruby) worker-0 working on job-7 (will take 80.0s to complete)
  81 >[  5.008029] (4:worker@Ruby) worker-2 working on job-6 (will take 5.0s to complete)
  82 >[  5.008029] (6:worker@Ruby) worker-4 working on job-5 (will take 40.0s to complete)
  83 >[ 10.008029] (3:worker@Ruby) worker-1 working on job-8 (will take 5.0s to complete)
  84 >[ 10.014105] (4:worker@Ruby) worker-2 working on job-9 (will take 160.0s to complete)
  85 >[170.018227] (1:client@Tremblay) received 10/10 results
  86 >[170.018227] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
  87 >[170.018227] (1:client@Tremblay) job-1 status=complete result_payload=worker-1
  88 >[170.018227] (1:client@Tremblay) job-2 status=complete result_payload=worker-2
  89 >[170.018227] (1:client@Tremblay) job-3 status=complete result_payload=worker-3
  90 >[170.018227] (1:client@Tremblay) job-4 status=complete result_payload=worker-4
  91 >[170.018227] (1:client@Tremblay) job-5 status=complete result_payload=worker-4
  92 >[170.018227] (1:client@Tremblay) job-6 status=complete result_payload=worker-2
  93 >[170.018227] (1:client@Tremblay) job-7 status=complete result_payload=worker-0
  94 >[170.018227] (1:client@Tremblay) job-8 status=complete result_payload=worker-1
  95 >[170.018227] (1:client@Tremblay) job-9 status=complete result_payload=worker-2