SessionHost Classe
Protocollo per consentire ad altri oggetti di "ospitare" una sessione. Ad esempio, un oggetto di destinazione può ospitare una sessione aperta e avere tutti i processi inviati tramite di esso per essere associati a tale sessione.
Esempio (processo da 1 a 3 verrà associato alla sessione "MySession"):
with target.open_session(name="MySession") as session:
job1 = target.submit(input_data=input_data, job_name="Job 1")
job2 = target.submit(input_data=input_data, job_name="Job 2")
job3 = target.submit(input_data=input_data, job_name="Job 3")
- Ereditarietà
-
SessionHost
Costruttore
SessionHost(*args, **kwargs)
Metodi
get_latest_session_id |
Ottiene l'ID sessione più recente (aperto) associato a questo oggetto. Questo ID viene usato per associare i processi alla sessione più recente (aperta). |
open_session |
Apre una sessione e associa tutti gli invii di processi futuri a tale sessione fino alla chiusura della sessione ,che avviene automaticamente dopo la chiusura di un con blocco. Esempio (processo da 1 a 3 verrà associato alla sessione "MySession"):
Nota: se l'host di sessione (in genere un di destinazione |
get_latest_session_id
Ottiene l'ID sessione più recente (aperto) associato a questo oggetto. Questo ID viene usato per associare i processi alla sessione più recente (aperta).
get_latest_session_id() -> str | None
Restituisce
Tipo | Descrizione |
---|---|
ID sessione più recente. |
open_session
Apre una sessione e associa tutti gli invii di processi futuri a tale sessione fino alla chiusura della sessione ,che avviene automaticamente dopo la chiusura di un con blocco.
Esempio (processo da 1 a 3 verrà associato alla sessione "MySession"):
with target.open_session(name="MySession") as session:
job1 = target.submit(input_data=input_data, job_name="Job 1")
job2 = target.submit(input_data=input_data, job_name="Job 2")
job3 = target.submit(input_data=input_data, job_name="Job 3")
Nota: se l'host di sessione (in genere un di destinazione
open_session(details: SessionDetails | None = None, id: str | None = None, name: str | None = None, job_failure_policy: str | SessionJobFailurePolicy | None = None, **kwargs) -> Session
Parametri
Nome | Descrizione |
---|---|
details
|
Modello di dettagli sessione contenente l'ID sessione, il nome, job_failure_policy, provider_id e la destinazione. Questo parametro deve essere passato contenente tutti i valori dei dettagli della sessione, gli stessi valori devono essere passati come singoli parametri. Valore predefinito: None
|
id
|
ID della sessione. Se non viene passato, verrà usato un uuid casuale. Valore predefinito: None
|
name
|
Nome della sessione. Se non viene passato, il nome verrà session-{session-id}. Valore predefinito: None
|
job_failure_policy
|
Criteri che determinano quando una sessione non riesce, chiude e non accetta altri processi. Valore predefinito: None
|
Restituisce
Tipo | Descrizione |
---|---|
Oggetto sessione con dettagli aggiornati dopo l'apertura. |