Perian Job Platform

flytekitplugins-perian_job

FlytekitCloud & Infrastructureperiangpuinfrastructure

Flyte Connector plugin for executing Flyte tasks on Perian Job Platform (perian.io).

Install

pip install flytekitplugins-perian_job

Quick Start(example, may need adjustment)

pip install flytekitplugins-perian_job

from flytekit import task, workflow
from flytekitplugins.perian_job import PerianConnector, PerianConfig, PerianContainerTask, PerianTask

@task(task_config=PerianContainerTask(...))
def my_task() -> None:
    ...

@workflow
def my_workflow() -> None:
    my_task()

Available Imports (4)

connectorPerianConnector

Flyte Connector for executing tasks on PERIAN Job Platform.

from flytekitplugins.perian_job import PerianConnector

configPerianConfig

Used to configure a Perian Task.

extends dataclass — configuration or data structure for plugin setup

from flytekitplugins.perian_job import PerianConfig

taskPerianContainerTask

A special task type for running Python container (not function) tasks on PERIAN Job Platform (perian.io).

extends PythonTask — a flyte task that can be used in workflows

from flytekitplugins.perian_job import PerianContainerTask

taskPerianTask

A special task type for running Python function tasks on PERIAN Job Platform (perian.io).

extends PythonFunctionTask — a flyte task that can be used in workflows

from flytekitplugins.perian_job import PerianTask

Dependencies

perian

Related Plugins

AWS Athena

Cloud & Infrastructure

Flyte backend can be connected with Athena. Once enabled, it allows you to query AWS Athena service (Presto + ANSI SQL Support) and retrieve typed schema (optionally).