
import multyvac

multyvac.config.set_key(api_key='admin', api_secret_key='12345', api_url='http://docker:8000/api')

jid = multyvac.shell_submit(cmd='for i in {1..10}; do echo $i && sleep 10; done')
print("Submitted job [{}].".format(jid))

job = multyvac.get(jid)
result = job.get_result()
print("Result: [{}]".format(result))


from __future__ import print_function

import multyvac
import sys

multyvac.config.set_key(api_key='admin', api_secret_key='12345', api_url='http://docker:8000/api')

jobs = {
    "stdout result": {
        "cmd": 'echo "success"',
    },
    "file result": {
        "cmd": 'echo "success" > /tmp/out',
        "_result_source": "file:/tmp/out",
    },
    "stdin": {
        "cmd": 'cat',
        "_stdin": "success",
    },
}

longest = 0
for name in jobs.keys():
    if len(name) > longest:
        longest = len(name)

success = 0
failure = 0

for (name, kwargs) in jobs.items():
    jid = multyvac.shell_submit(**kwargs)
    print("{:<{}}: job {} ...".format(name, longest, jid), end='')
    result = multyvac.get(jid).get_result().strip('\n')
    print(" result [{}]".format(result))
    if result == "success":
        success += 1
    else:
        failure += 1

print("{} pass / {} fail".format(success, failure))
if failure > 0:
    sys.exit(1)

Test different mechanisms for job submission.
Test different mechanisms for job submission.

+ 
+ from __future__ import print_function
  
  import multyvac
+ import sys
  
  multyvac.config.set_key(api_key='admin', api_secret_key='12345', api_url='http://docker:8000/api')
  
- jid = multyvac.shell_submit(cmd='for i in {1..10}; do echo $i && sleep 10; done')
- print("Submitted job [{}].".format(jid))
+ jobs = {
+     "stdout result": {
+         "cmd": 'echo "success"',
+     },
+     "file result": {
+         "cmd": 'echo "success" > /tmp/out',
+         "_result_source": "file:/tmp/out",
+     },
+     "stdin": {
+         "cmd": 'cat',
+         "_stdin": "success",
+     },
+ }
  
- job = multyvac.get(jid)
- result = job.get_result()
- print("Result: [{}]".format(result))
+ longest = 0
+ for name in jobs.keys():
+     if len(name) > longest:
+         longest = len(name)
  
+ success = 0
+ failure = 0
+ 
+ for (name, kwargs) in jobs.items():
+     jid = multyvac.shell_submit(**kwargs)
+     print("{:<{}}: job {} ...".format(name, longest, jid), end='')
+     result = multyvac.get(jid).get_result().strip('\n')
+     print(" result [{}]".format(result))
+     if result == "success":
+         success += 1
+     else:
+         failure += 1
+ 
+ print("{} pass / {} fail".format(success, failure))
+ if failure > 0:
+     sys.exit(1)
+ 
Test different mechanisms for job submission.
## Code Before:

import multyvac

multyvac.config.set_key(api_key='admin', api_secret_key='12345', api_url='http://docker:8000/api')

jid = multyvac.shell_submit(cmd='for i in {1..10}; do echo $i && sleep 10; done')
print("Submitted job [{}].".format(jid))

job = multyvac.get(jid)
result = job.get_result()
print("Result: [{}]".format(result))

## Instruction:
Test different mechanisms for job submission.
## Code After:

from __future__ import print_function

import multyvac
import sys

multyvac.config.set_key(api_key='admin', api_secret_key='12345', api_url='http://docker:8000/api')

jobs = {
    "stdout result": {
        "cmd": 'echo "success"',
    },
    "file result": {
        "cmd": 'echo "success" > /tmp/out',
        "_result_source": "file:/tmp/out",
    },
    "stdin": {
        "cmd": 'cat',
        "_stdin": "success",
    },
}

longest = 0
for name in jobs.keys():
    if len(name) > longest:
        longest = len(name)

success = 0
failure = 0

for (name, kwargs) in jobs.items():
    jid = multyvac.shell_submit(**kwargs)
    print("{:<{}}: job {} ...".format(name, longest, jid), end='')
    result = multyvac.get(jid).get_result().strip('\n')
    print(" result [{}]".format(result))
    if result == "success":
        success += 1
    else:
        failure += 1

print("{} pass / {} fail".format(success, failure))
if failure > 0:
    sys.exit(1)
