phenotypic.sdk_.slurm.submit_drip_feed_start

phenotypic.sdk_.slurm.submit_drip_feed_start(chunk_scripts: List[Path], dispatcher_scripts: List[Path], *, finalizer_script: Path | None = None, continuation_dependency_kind: Literal['afterany', 'afterok'] = 'afterany', output_dir: Path | None = None, generation: str | None = None) → Tuple[List[str], str | None]

Submit the first chunk and first dispatcher to start a drip-feed chain.

Parameters:

• chunk_scripts (List[Path]) – Ordered list of chunk script paths (must be non-empty).

• dispatcher_scripts (List[Path]) – Dispatcher scripts from generate_dispatcher_chain() (may be empty for single-chunk).

• finalizer_script (Path | None) – Terminal finalizer submitted after the only chunk when no dispatcher is required.

• continuation_dependency_kind (Literal['afterany', 'afterok']) – Dependency condition for the initial dispatcher or single-chunk finalizer.

• output_dir (Path | None) – Explicit lifecycle output root for attempt-scoped chains.

• generation (str | None) – Explicit lifecycle generation for attempt-scoped chains.

Returns:

Tuple of (job_ids, warning_message). job_ids contains the submitted job IDs (1 or 2). warning_message is None on success, or a string with recovery instructions if the dispatcher submission failed (chunk 0 was still submitted).

Raises:

RuntimeError – If the first chunk submission fails.

Return type:

Tuple[List[str], str | None]