Quick question about using dynamic workflows with the imperative style

create_node()

. We have a bunch of

@tasks

which have dependencies on one another, but they are not explicit (nothing is returned or passed in). We can easily use the imperative style to define the order of the tasks in a regular

@workflow

. Does the imperative style also work for

@dynamic

workflows?

Hey, it seems that the UpdateProjectDomainAttributes fails on the actual update flyteadmin:v0.6.92 , is it expected functionality? It used to work with simply overriding the existing domain attribute [error in 🧵 ]

Did anyone run into issue with Flyte retrieving items from storage blob? [1/1] currentAttempt done. Last Error: USER::load_distribution(additional_distribution, dest_dir) │ │ │ │ /usr/local/lib/python3.10/site-packages/flytekit/core/utils.py:295 in │ │ wrapper │ │ │ │ ❱ 295 │ │ │ │ return func(*args, **kwargs) │ │ │ │ /usr/local/lib/python3.10/site-packages/flytekit/tools/fast_registration.py: │ │ 113 in download_distribution │ │ │ │ ❱ 113 │ FlyteContextManager.current_context().file_access.get_data(additio │ │ │ │ /usr/local/lib/python3.10/site-packages/flytekit/core/data_persistence.py:30 │ │ 1 in get_data │ │ │ │ ❱ 301 │ │ │ raise FlyteAssertion( │ ╰──────────────────────────────────────────────────────────────────────────────╯ FlyteAssertion: Failed to get data from gs://flyte-blob-storage/flytesnacks/development/MHEQCB3WRLH247GOTRY3CZQIWE====== /fastea66e2416c583fdc6995e9e030c414bf.tar.gz to /root/ (recursive=False). Original exception: 403, message='Forbidden', url=URL('https://storage.googleapis.com/download/storage/v1/b/flyte-blob-storage /o/flytesnacks%2Fdevelopment%2FMHEQCB3WRLH247GOTRY3CZQIWE======%2Ffastea66e2416c 583fdc6995e9e030c414bf.tar.gz?alt=media') The https link seems to include extra entries which results in 403 error

how do you delete a flyte project? we had a case of

seedProjects

gone wrong, and now our flyteUI is full of projects we want to remove.

pyflyte

vs

flytectl

question; is it possible to package and register from a

flyte-package.tgz

as two separate steps, all within

pyflyte

? Or is it necessary to pass the

flyte-package.tgz

file to flytectl after packaging in

pyflyte

?

If I understand correctly,

@dynamic

is a workflow whose DAG is created during runtime (unlike

@workflow

whose DAG is created during compile time), which makes it more flexible. So my question is, what are the downsides of

@dynamic

compared to a static

@workflow

? Why aren’t all flyte workflows

@dynamic

(kind of like how all PyTorch computational graphs are by default dynamic)? Are there meaningful performance penalties to using

@dynamic

?

Hello all I'm getting this error when trying to create a task with custom object:

ValueError: Only generic univariate typing.List[T] type is supported.

I tried to use the example in doc, https://flyte--943.org.readthedocs.build/projects/cookbook/en/943/auto/core/type_system/custom_objects.html

Hi everyone… getting a ‘NoneType’ object has no attribute ‘inputs’ trying to execute a launch plan. the workflow doesn’t have inputs parameters. any ideas?

from flytekit import Email, LaunchPlan
from flytekit.models.core.execution import WorkflowExecutionPhase
from flytekit.remote import FlyteRemote
from flytekit.configuration import Config

remote = FlyteRemote(
    config=Config.for_endpoint(endpoint="dns:///flyte.eks.tech"),
    default_project="flytesnacks",
    default_domain="development",
)

wf = remote.fetch_workflow(name="parent_workflows.workflows.example.my_wf", version="Mh7JCmzuS6MJr2XWw5ST-Q==", project="flytesnacks", domain="development")
print(wf) #prints correctly
lp = LaunchPlan.get_or_create(wf)
print(lp) #prints correctly
execution = remote.execute(lp, inputs={}, execution_name="test lanuch plan", wait=False) #fails here 'NoneType' object has no attribute 'inputs'
print(execution)

Is it possible to request resources for a task dynamically? We have a task that depending on the input could require a different amount of resources.

Anyone has any idea what I’m doing wrong here?