jobflow_remote.jobs.submit module#

jobflow_remote.jobs.submit.submit_flow(flow: jobflow.Flow | jobflow.Job | list[jobflow.Job], worker: str | None = None, project: str | None = None, exec_config: str | ExecutionConfig | None = None, resources: dict | QResources | None = None, allow_external_references: bool = False) list[int][source]#

Submit a flow for calculation to the selected Worker.

This will not start the calculation but just add to the database of the calculation to be executed.

Parameters:
  • flow – A flow or job.

  • worker – The name of the Worker where the calculation will be submitted. If None, use the first configured worker for this project.

  • project – the name of the project to which the Flow should be submitted. If None the current project will be used.

  • exec_config (str or ExecutionConfig) – the options to set before the execution of the job in the submission script. In addition to those defined in the Worker.

  • resources (Dict or QResources) – information passed to qtoolkit to require the resources for the submission to the queue.

  • allow_external_references – If False all the references to other outputs should be from other Jobs of the Flow.

Returns:

The list of db_ids of the submitted Jobs.

Return type:

List of int