prefect_gcp.utilities

Functions

slugify_name ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L10" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

slugify_name(name: str, max_length: int = 30) -> Optional[str]

Slugify text for use as a name.

Keeps only alphanumeric characters and dashes, and caps the length of the slug at 30 chars.

The 30 character length allows room to add a uuid for generating a unique name for the job while keeping the total length of a name below 63 characters, which is the limit for Cloud Run job names.

Args:

• name: The name of the job

Returns:

• The slugified job name or None if the slugified name is empty

Classes

Job ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L70" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

Utility class to call GCP jobs API and interact with the returned objects.

Methods:

create ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L142" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

create(client: Resource, namespace: str, body: dict)

Make a create request to the GCP jobs API.

delete ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L149" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

delete(client: Resource, namespace: str, job_name: str)

Make a delete request to the GCP jobs API.

get ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L127" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get(cls, client: Resource, namespace: str, job_name: str)

Make a get request to the GCP jobs API and return a Job instance.

has_execution_in_progress ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L101" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

has_execution_in_progress(self) -> bool

See if job has a run in progress.

is_ready ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L95" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

is_ready(self) -> bool

Whether a job is finished registering and ready to be executed

run ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L156" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

run(client: Resource, namespace: str, job_name: str)

Make a run request to the GCP jobs API.

Execution ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L163" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

Utility class to call GCP executions API and interact with the returned objects.

Methods:

condition_after_completion ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L180" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

condition_after_completion(self)

Returns Execution condition if Execution has completed.

get ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L195" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get(cls, client: Resource, namespace: str, execution_name: str)

Make a get request to the GCP executions API and return an Execution instance.

is_running ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L176" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

is_running(self) -> bool

Returns True if Execution is not completed.

succeeded ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-gcp/prefect_gcp/utilities.py#L186" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

succeeded(self)

Whether or not the Execution completed is a successful state.