`airflow.providers.google.cloud.triggers.mlengine`¶

模块内容¶

类¶

MLEngineStartTrainingJobTrigger

MLEngineStartTrainingJobTrigger 在触发器工作器上运行，以执行启动训练作业操作。

class airflow.providers.google.cloud.triggers.mlengine.MLEngineStartTrainingJobTrigger(conn_id, job_id, region, poll_interval=4.0, package_uris=None, training_python_module=None, training_args=None, runtime_version=None, python_version=None, job_dir=None, project_id=PROVIDE_PROJECT_ID, labels=None, gcp_conn_id='google_cloud_default', impersonation_chain=None)[源代码]¶

基类: airflow.triggers.base.BaseTrigger

MLEngineStartTrainingJobTrigger 在触发器工作器上运行，以执行启动训练作业操作。

参数

conn_id (str) – Google Cloud 连接 ID 的引用
job_id (str) – 作业的 ID。它将附加作业配置的哈希值
project_id (str) – 作业运行的 Google Cloud 项目
poll_interval (float) – 检查状态的轮询间隔（秒）

serialize()[源代码]¶

序列化 MLEngineStartTrainingJobTrigger 参数和类路径。

async run()[源代码]¶

获取当前作业执行状态并生成一个 TriggerEvent。

airflow.providers.google.cloud.triggers.mlengine¶

模块内容¶

类¶

`airflow.providers.google.cloud.triggers.mlengine`¶