airflow.providers.google.cloud.links.ray

Attributes

RAY_JOB_BASE_LINK

RAY_JOB_LINK

Classes

RayJobLink

Helper class for constructing Job on Ray cluster Link.

Module Contents

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

Helper class for constructing Job on Ray cluster Link.

name = 'Ray Job'[source]

Name of the link. This will be the button name on the task UI.

key = 'ray_job'[source]
format_str = 'http://{cluster_address}/#/jobs/{job_id}'[source]
classmethod persist(context, **value)[source]

Push arguments to the XCom to use later for link formatting at the get_link method.

Note: for Airflow 2 we need to call this function with context variable only where we have the extra_links_params property method defined

Was this entry helpful?