promptflow.batch Modul#

class promptflow.batch.BatchEngine(flow_file: Union[Path, Callable], working_dir: Optional[Path] = None, *, connections: Optional[dict] = None, storage: Optional[AbstractRunStorage] = None, batch_timeout_sec: Optional[int] = None, line_timeout_sec: Optional[int] = None, worker_count: Optional[int] = None, init_kwargs: Optional[Dict[str, Any]] = None, **kwargs)#

Basiert auf: object

Diese Klasse wird verwendet, um Flows im Batch-Modus auszuführen

cancel()#

Den Batch-Lauf abbrechen

classmethod register_executor(language: str, executor_proxy_cls: Type[AbstractExecutorProxy])#

Registrieren Sie eine Executor-Proxy-Klasse für eine bestimmte Programmiersprache.

Diese Funktion dient zur Kompatibilität mit der älteren Version von promptflow-runtime; sie leitet die Registrierung an die ExecutorProxyFactory weiter.

run(input_dirs: Dict[str, str], inputs_mapping: Dict[str, str], output_dir: Path, run_id: Optional[str] = None, max_lines_count: Optional[int] = None, raise_on_line_failure: Optional[bool] = False, resume_from_run_storage: Optional[AbstractBatchRunStorage] = None, resume_from_run_output_dir: Optional[Path] = None, executor_proxy: Optional[AbstractExecutorProxy] = None) → BatchResult#

Flow im Batch-Modus ausführen

Parameter:

  • input_dirs (Dict[str, str]) – Die Verzeichnispfade der Eingabedateien

  • inputs_mapping (Dict[str, str]) – Die Zuordnung von Eingabenamen zu ihren entsprechenden Werten.

  • output_dir (Der Verzeichnispfad der Ausgabedateien) – Ausgabeverzeichnis

  • run_id (Optional[str]) – Die Ausführungs-ID dieses Laufs

  • max_lines_count (Optional[int]) – Die maximale Anzahl von Eingaben. Wenn es None ist, werden alle Eingaben verwendet.

  • raise_on_line_failure (Optional[bool]) – Ob eine Ausnahme ausgelöst werden soll, wenn eine Zeile fehlschlägt.

  • resume_from_run_storage (Optional[AbstractRunStorage]) – Der Ausführungsspeicher, um den Flow-Lauf und den Knotenlauf aus dem ursprünglichen Lauf zu laden. Das Wiederaufnahmeverhalten besteht darin, erfolgreiche Zeilenergebnisse des ursprünglichen Laufs wiederzuverwenden und die verbleibenden/fehlgeschlagenen Zeilen auszuführen/neu auszuführen.

  • resume_from_run_output_dir (Optional[Path]) – Das Ausgabeverzeichnis des ursprünglichen Laufs.

Gibt zurück:

Das Ergebnis dieses Batch-Laufs

Rückgabetyp:

BatchResult

class promptflow.batch.BatchResult(status: Status, total_lines: int, completed_lines: int, failed_lines: int, node_status: Mapping[str, int], start_time: datetime, end_time: datetime, metrics: Mapping[str, str], system_metrics: SystemMetrics, error_summary: ErrorSummary)#

Basiert auf: object

Das Ergebnis eines Batch-Laufs.

completed_lines: int#
classmethod create(start_time: datetime, end_time: datetime, line_results: List[LineResult], aggr_result: AggregationResult, status: Status = Status.Completed, exception: Optional[Exception] = None) → BatchResult#
end_time: datetime#
error_summary: ErrorSummary#
failed_lines: int#
metrics: Mapping[str, str]#
node_status: Mapping[str, int]#
start_time: datetime#
status: Status#
system_metrics: SystemMetrics#
total_lines: int#