airflow.providers.google.cloud.links.dataform¶

This module contains Google Dataflow links.

Attributes¶

`DATAFORM_BASE_LINK`
`DATAFORM_WORKFLOW_INVOCATION_LINK`
`DATAFORM_REPOSITORY_LINK`
`DATAFORM_WORKSPACE_LINK`

`DataformWorkflowInvocationLink`	Helper class for constructing Dataflow Job Link.
`DataformRepositoryLink`	Helper class for constructing Dataflow repository link.
`DataformWorkspaceLink`	Helper class for constructing Dataform workspace link.

airflow.providers.google.cloud.links.dataform.DATAFORM_BASE_LINK = '/bigquery/dataform'[source]¶

airflow.providers.google.cloud.links.dataform.DATAFORM_WORKFLOW_INVOCATION_LINK = '/bigquery/dataform/locations/{region}/repositories/{repository_id}/workflows/{workflow_invocatio...[source]¶

airflow.providers.google.cloud.links.dataform.DATAFORM_REPOSITORY_LINK = '/bigquery/dataform/locations/{region}/repositories/{repository_id}/details/workspaces?project={p...[source]¶

airflow.providers.google.cloud.links.dataform.DATAFORM_WORKSPACE_LINK = '/bigquery/dataform/locations/{region}/repositories/{repository_id}/workspaces/{workspace_id}/fil...[source]¶

class airflow.providers.google.cloud.links.dataform.DataformWorkflowInvocationLink[source]¶

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

Helper class for constructing Dataflow Job Link.

name = 'Dataform Workflow Invocation'[source]¶: Name of the link. This will be the button name on the task UI.

format_str = '/bigquery/dataform/locations/{region}/repositories/{repository_id}/workflows/{workflow_invocatio...[source]¶

static persist(operator_instance, context, project_id, region, repository_id, workflow_invocation_id)[source]¶

class airflow.providers.google.cloud.links.dataform.DataformRepositoryLink[source]¶

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

Helper class for constructing Dataflow repository link.

name = 'Dataform Repository'[source]¶: Name of the link. This will be the button name on the task UI.

format_str = '/bigquery/dataform/locations/{region}/repositories/{repository_id}/details/workspaces?project={p...[source]¶

static persist(operator_instance, context, project_id, region, repository_id)[source]¶

class airflow.providers.google.cloud.links.dataform.DataformWorkspaceLink[source]¶

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

Helper class for constructing Dataform workspace link.

name = 'Dataform Workspace'[source]¶: Name of the link. This will be the button name on the task UI.

format_str = '/bigquery/dataform/locations/{region}/repositories/{repository_id}/workspaces/{workspace_id}/fil...[source]¶

static persist(operator_instance, context, project_id, region, repository_id, workspace_id)[source]¶