Synnefo » snf-ganeti

  """

  ToStdout("Testing job dependencies")

  try:

    SubmitOpCode(opcodes.OpTestDelay(duration=0, depends=[(-1, None)]), cl=cl)

  except errors.GenericError, err:

    if opts.debug:

                                           ht.TOr(ht.TNonEmptyString,

                                                  ht.TJobId)])))

  result = cl.SubmitManyJobs(jobs)

  if not check_fn(result):

    raise errors.OpExecError("Job submission doesn't match %s: %s" %

        (4, 2, priority + offset),

        ])

  for before, after, failpriority in testdata:

    ops = []

    ops.extend([opcodes.OpTestDelay(duration=0) for _ in range(before)])

    ops.extend([opcodes.OpTestDelay(duration=0) for _ in range(after)])

    try:

      cl.SubmitJob(ops)

    except errors.GenericError, err:

      if opts.debug:

      ops,

      ]

    try:

      cl.SubmitManyJobs(jobs)

    except errors.GenericError, err:

      if opts.debug: