Issue: I have been following the docs here, but while running the code

unionml serve app:app --reload --model-path /tmp/model_object.pt

, I get this error on the browser

{"detail": "Method Not Allowed"}

and in the terminal, it is showing:

INFO: 127.0.0.1:64825 - "GET /predict HTTP/1.1" 405 Method Not Allowed

My Folder structure looks like this (i.e in same directory): -> app.py -> client.py -> main.py (same code as app.py) Thanks,

Good morning! We’re trying out Dynamic tasks for distributed computing/forecasting and notice it takes over 8 minutes for Flyte to kick off the first task. Is this normal? (@Kelsey Messer FYI)

been reading up on some of the new features and found out about this approve https://github.com/flyteorg/flytesnacks/blob/master/cookbook/core/control_flow/waiting_for_external_inputs.py#L150-L158. When I tried doing fast registration after copying pasting, it errors out with the following.

RPC Failed, with Status: StatusCode.INTERNAL
	details: failed to compile workflow for [resource_type:WORKFLOW project:"flytetester" domain:"development" name:"flyte.example.reporting_with_approval_wf" version:"unique-version" ] with err failed to compile workflow with err Collected Errors: 2
	Error 0: Code: ParameterNotBound, Node Id: end-node, Description: Parameter not bound [o0].
	Error 1: Code: VariableNameNotFound, Node Id: n3, Description: Variable [o0] not found on node [n3].

Hey all! anyone has given it a try to convert Kedro Pipelines to Flyte Workflows. We are starting to use flyte and it would be nice to have some kedro pipelines running there

Bad news @Nastya Rusina, I bounced to Flyte Console

v0.55.0

and I'm back to

Failed to fetch data: invalid wire type 4 at offset 1

for

/console

Hi there! How to increase the allowed output size of the node?

RuntimeExecutionError: failed during plugin execution, caused by: failed to execute handle for plugin [k8s-array]: output file @[] is too large [255540150] bytes, max allowed [10485760] bytes

Hi, I have one question regarding the for loop in workflow. I wanted to have a code like the following

@task
def example_task(num:int) -> None:
    .....

@workflow
def test_workflow() -> None:
    for i in range(5):
        example_test(num=i)

It seems one way is that I can use dynamic workflow. However, in dynamic workflow, the tasks in the for loop will be running in parallel. I wanted the tasks can be running in sequence. So do you have a method to realize the for loop in sequence. Thanks!

Hi, I am struggling to inject secrets at execution time into tasks and workflows via the flytekit api. This is my task taken from the mnist training example

@task(
    retries=2,
    cache=True,
    cache_version="1.0",
    requests=Resources(gpu=gpu, mem=mem, storage=storage),
    limits=Resources(gpu=gpu, mem=mem, storage=storage),
    secret_requests=[Secret(group="wandb-secrets", key="API_KEY")],
)
def pytorch_mnist_task(hp: Hyperparameters) -> TrainingOutputs:
    secrets = current_context().secrets
    wandb_api_key = secrets.get(group="wandb-secrets", key="API_KEY")

And I would like to call a remote execution and inject the secret at the same time like this:

current_config = Config.auto()

remote = FlyteRemote(config=current_config)
flyte_workflow = remote.fetch_workflow(name=workflow_name, version="v1", project="flytesnacks", domain="development",)
workflow_execution = remote.execute(entity=flyte_workflow, inputs={"hp": Hyperparameters(epochs=2, batch_size=128)}, project="flytesnacks", domain="development",)

But after checking out the docs, I am confused about where to put the secret and the format it should be in. I noticed the SecretsConfig, but it isn't clear to me about how to utilize that here since it appears to require a file. Can I not specific an execution time environment variable?

hello! Quick question - what's best pattern of triggering flyte workflows based on events (similar to argo-events)? Like, trigger a workflow when new file is uploaded to s3 bucket or a pubsub message is received?

Hi all, new here. I didn't see a beginner's channel, so I'll ask what seems like a silly question here. I followed the instructions described here. I used Python 3.10 on MacBook Pro with M2 Pro chipset. I'm getting the following error:

Failed with Unknown Exception <class 'TypeError'> Reason: Encountered error while executing workflow 'example.training_workflow':

Error encountered while executing 'training_workflow':

Failed to convert outputs of task 'example.get_data' at position 0:

[Errno 2] Failed to open local file '/var/folders/vs/v9fd0vyx6b735n5_l607sq440000gn/T/flyte-nl8jmq53/raw/2bb31bdcb6e0b0733d1bad9b87a3e886/00000'. Detail: [errno 2] No such file or directory

So I did a little digging. From the exception stacktrace it seems like the error happens when attempting to write the output. While debugging I found that indeed this folder isn't created. The temp folder

/var/folders/vs/v9fd0vyx6b735n5_l607sq440000gn/T/flyte-nl8jmq53/

does exist, but the

raw

sub folder isn't. I kept debugging until I noticed several things (in reversed order 🙂). The method

flytekit.core.data_persistence.FileAccessProvider.get_random_remote_path

- the default remote is expectedly

LocalFileSystem

.

self._default_protocol

is

"file"

but in that method, this following line returns `('file', 'local')`:

default_protocol = self._default_remote.protocol

This causes

get_random_remote_path

to eventually return a path that starts with

file:///...

. Right after getting the random path, in

flytekit.types.structured.basic_dfs.PandasToParquetEncodingHandler.encode

these lines happen:

if not ctx.file_access.is_remote(uri):
    Path(uri).mkdir(parents=True, exist_ok=True)

is_remote

returns

True

but apparently

Path.mkdir

when operating on

file://...

path, does NOTHING. So the necessary folder hierarchy does not exist and the code fails. Potential root causes: 1.

fsspec

for some reason, returns

('file', 'local')

instead of

file

. 2. Another option, that

Flyte

code in

flytekit.core.data_persistence.FileAccessProvider.get_random_remote_path

if type(default_protocol) == list:
            default_protocol = default_protocol[0]

was supposed to test

tuple

condition as well - this would have probably solved the issue 3. Another possiblity is my Mac... maybe

Path

behaves weirdly on Mac