flytekitplugins.perian_job.agent

Directory

Classes

Variables

flytekitplugins.perian_job.agent.PerianAgent

Flyte Agent for executing tasks on PERIAN Job Platform

def PerianAgent()

Methods

create()

def create(
    task_template: flytekit.models.task.TaskTemplate,
    inputs: typing.Optional[flytekit.models.literals.LiteralMap],
    output_prefix: typing.Optional[str],
    kwargs,
) -> flytekitplugins.perian_job.agent.PerianMetadata

Return a resource meta that can be used to get the status of the task.

delete()

def delete(
    resource_meta: flytekitplugins.perian_job.agent.PerianMetadata,
    kwargs,
)

Delete the task. This call should be idempotent. It should raise an error if fails to delete the task.

get()

def get(
    resource_meta: flytekitplugins.perian_job.agent.PerianMetadata,
    kwargs,
) -> flytekit.extend.backend.base_agent.Resource

Return the status of the task, and return the outputs in some cases. For example, bigquery job can’t write the structured dataset to the output location, so it returns the output literals to the propeller, and the propeller will write the structured dataset to the blob store.

Properties

flytekitplugins.perian_job.agent.PerianMetadata

Metadata for PERIAN jobs

class PerianMetadata(
    job_id: str,
)

Methods

decode()

def decode(
    data: bytes,
) -> ResourceMeta

Decode the resource meta from bytes.

encode()

def encode()

Encode the resource meta to bytes.