big-easter-12386
10/27/2023, 5:13 PMbig-easter-12386
10/27/2023, 5:21 PMfrom flytekit import workflow, task
from dataclasses import dataclass
from dataclasses_json import dataclass_json
@dataclass_json
@dataclass
class ExampleInput:
name: str
age: int
is_cool: bool
@task
def is_cool_task(input: ExampleInput) -> bool:
return input.is_cool
@workflow
def my_workflow(input: ExampleInput) -> bool:
return is_cool_task(input=input)
big-easter-12386
10/27/2023, 5:30 PM{
"domain": "development",
"inputs": {
"scalar": [
{
"input": [
{
"name": "test"
},
{
"age": 5
},
{
"is_cool": true
}
]
}
]
},
"name": "flyte.my_project.raw.my_workflow",
"project": "my-project"
}
full-evening-87657
10/29/2023, 3:07 PM# from flytekit.core.context_manager import FileAccessProvider
from flytekit.configuration import Config, DataConfig, S3Config
from flytekit.remote import FlyteRemote
import json
MyConfig = Config.for_endpoint(
endpoint="0.0.0.0:30080",
insecure=True,
data_config=DataConfig(
s3=S3Config(endpoint="<http://localhost:30002>", access_key_id="minio", secret_access_key="miniostorage")
)
)
remote = FlyteRemote(
# Fetch workflow
config=MyConfig,
default_project="flytesnacks",
default_domain="development",
)
remote.execute("flytesnacks", "development", "hello_world", inputs={"name": "world"})
big-easter-12386
10/30/2023, 9:03 AMfull-evening-87657
10/30/2023, 9:13 AM