nv_dfm_core.targets.flare.FlareSessionDelegate#

class nv_dfm_core.targets.flare.FlareSessionDelegate(session, federation_name, homesite, logger, user=None, flare_workspace=None, job_workspace=None, admin_package=None)[source]#
Parameters:

  • session (Any)

  • federation_name (str)

  • homesite (str)

  • logger (Logger)

  • user (str | None)

  • flare_workspace (Path | None)

  • job_workspace (Path | None)

  • admin_package (Path | None)

execute(pipeline, next_frame, input_params, callback_runner, debug, options=None, force_modgen=False)[source]#

Execute a pipeline.

Parameters:

  • pipeline (PreparedPipeline) – The pipeline to execute.

  • input_params (list[tuple[Frame, dict[str, Any]]]) – The input parameters for the pipeline. Can be a single set or parameters or a sequence of parameters which will be submitted in sequence.

  • callback_runner (CallbackRunner) – The callback runner for receiving results.

  • next_frame (Frame)

  • debug (bool)

  • options (FlareOptions | None)

  • force_modgen (bool)

Returns:

The job object.

Return type:

Job

reattach(job_id, callback_runner)[source]#

Reattach to an existing FLARE job.

Parameters:

  • job_id (str) – The ID of the job to reattach to

  • callback_runner (CallbackRunner | None) – The callback runner for receiving results, or None for informational-only attachment (status/abort only).

Returns:

Job object for the existing FLARE job. If job_id is not found, returns a job that will report UNKNOWN status.

Return type:

Job