Hi Everyone, I'm new to prefect and I'm running into the following issue. I defined a task and inside a flow block I call this task. It happens that I expect the return of this task to be a list of urls(variable "extratos"), but don't know why I'm getting the following error message when "len(arquivos_extrato" is run: "object of type 'GetItem' has no len()". sharepoint4 is a customized class that i have built and the function listar_arquivos() is part of this class. My code is something like this: Can someone help me to understand why am I getting a GetItem object and not a list ?

Okay so I have my container built on azure container registry, but Docker() storage refuses to connect. How do I choose the container in Azure Container registry?

Hi folks, is it possible to call a task inside another task? Something like this: def function_a(): c = a + b return c task def do_something(): y = function(a) return y

so I have my flow in one file and then the tasks in another file. I finally got them to play nicely with Docker storage, but now in the RUN python /opt/prefect/healthcheck.py, it can't find the file that is in the same folder as the flow.

System Version check: OK
/opt/prefect/healthcheck.py:130: UserWarning: Flow uses module which is not importable. Refer to documentation on how to import custom modules <https://docs.prefect.io/api/latest/storage.html#docker>
  flows = cloudpickle_deserialization_check(flow_file_paths)
Traceback (most recent call last):
  File "/opt/prefect/healthcheck.py", line 130, in <module>
    flows = cloudpickle_deserialization_check(flow_file_paths)
  File "/opt/prefect/healthcheck.py", line 43, in cloudpickle_deserialization_check
    flows.append(cloudpickle.loads(flow_bytes))
ModuleNotFoundError: No module named "Module"

hey team - orion 2.0b1 is throwing some typer errors on success (I can see they are succeeding but it looks potentially misleading)

Set default storage to 'local'.
Traceback (most recent call last):
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/prefect/cli/base.py", line 58, in wrapper
    return fn(*args, **kwargs)
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/prefect/utilities/asyncio.py", line 120, in wrapper
    return run_async_in_new_loop(async_fn, *args, **kwargs)
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/prefect/utilities/asyncio.py", line 67, in run_async_in_new_loop
    return anyio.run(partial(__fn, *args, **kwargs))
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/anyio/_core/_eventloop.py", line 56, in run
    return asynclib.run(func, *args, **backend_options)
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 233, in run
    return native_run(wrapper(), debug=debug)
  File "/usr/lib/python3.9/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/usr/lib/python3.9/asyncio/base_events.py", line 642, in run_until_complete
    return future.result()
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 228, in wrapper
    return await func(*args)
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/prefect/cli/storage.py", line 136, in create
    exit_with_success(f"Set default storage to {name!r}.")
  File "/home/brad/.local/pipx/venvs/prefect/lib/python3.9/site-packages/prefect/cli/base.py", line 193, in exit_with_success
    raise typer.Exit(0)
click.exceptions.Exit: 0
An exception occurred.

Orion Question - is there a way to see flow schematic in Orion UI outside of flow run like Prefect 1.0 ?

Has anybody consume Prefect api in C# application?

How can I setup in Orion the task runner at deployment? I want to be able to change the mode between local dev and prod. I can only see how to do that for flow runners at the deployment level

hi all, maybe a newbie Orion question - how can I use more than one Python file to describe a flow with multiple tasks (we've got tons of internal ML libraries)? apart from putting all those in a Docker image, I haven't found a way for now

Can we schedule each task at a different time inside a single flow? Example: a Flow is cronned for 3pm and it has TASK A, B, C. Task A should start at 3 pm but Task B and Task C should start at 4:30 pm and 5pm respectively.

Hello, I have some questions. Please look at my figures. I understood Prefect works like figure 1(1 Pod or container for Agent) with autoscailing by Dask. Did I understand correctly? Plus, is there a way to use Prefect like figure 2(N Pods for flow)

Hello. Is it possible using prefect.Client or graphql get upstream task_run_ids by task_run_id?

Hey all! Quick reminder that PrefectLive is happening today at 3p Eastern with Chris White. Hope to see you on Twitch! https://prefect-community.slack.com/archives/C036FRC4KMW/p1647289203959699

Hey All I have a flow with "*state_handlers*" to slack and some api. Regarding that I have 2 questions: 1. When I change the flow's state from the Ui to Failed or Cancelled , I don't get any message from the handler , it's like it doesn't trigger the state handlers, Am I correct? 2. I want to create API call to the prefect server to change state or cancel flow_run, is it supposed to trigger the state handlers?

Hello everyone! I have a question about Orion s3 storage. When I created a test deployment, a file was created on my bucket, but when I tried to run the deployment, I got this error(in the thread) Of note: I use corporate AWS account and do not have full S3 Access, could this be the core of the issue?

we just (yesterday?) started running into a cloudpickle error when starting flow runs:

prefect.engine.signals.FAIL: Flow finished in state <Failed: "Failed to load and execute flow run: FlowStorageError('An error occurred while unpickling the flow:\n  AttributeError("\'Comment\' object has no attribute \'_end\'")')">

the flows are stored in GCS, python is 3.9.10 both locally (MacOS) and remote (docker+k8s). same prefect+cloudpickle versions. I've had the same thing happen before when python versions don't match but bumping has always fixed it, not really sure what else to look into now. any suggestions...?

Can I reuse a single Docker storage object for multiple registered flows?

Hi Prefect Experts - Is it possible to not display generated tasks like

List

and

Dict

from the visual schematic displayed in the UI?

Highlighting this morning's news here - today we announced Club :42:, our ambassador program! Some of our most experienced and dedicated community members have come together to help the community grow and thrive. 🥂 Here's to the 😛refect: community! https://prefect-community.slack.com/archives/CKNSX5WG3/p1647439185450549

Hi, I'm trying to run DataBricks Tasks using a docker agent. However the flow is failing when importting de DB tasks. When writting from prefect.tasks.databricks.databricks_get_job_id import DatabricksGetJobID, it fails with: 'ModuleNotFoundError: No module named 'pydantic''. I'm using the latest-python3.8 docker image

Hi, I have a flows.json that contains the metadata for a flow. I want to register this flow inside of another prefect flow. Is that possible?

hello, i am having issues with installing prefect 2.0 in my aws. I have a ubuntu 18.0 running which comes with a older version of sqlite3. Prefect 2.0 uses version greater than 3.24. is there anyway i can not install the sqlite3 depdency when installing prefect? @Kevin Kho @Anna Geller

Hi all! 👋 Sorry for the late cancellation but we had to move PrefectLive to tomorrow at 2p Eastern as @Chris White had some issues come up. Apologies again, I know you probably had your popcorn popped but we'll see you LIVE 📺 in under 24 hours.

Hi, I am running on prefect UI and getting this attribute error: can't get attribute 'get_target_name" on <module prefect_scripts.tasks.trade_cache_tasks'. the trade_cache_task is like below, similar structure works fine on other scripts, anyone has any ideas?

def get_target_name(x, **kwargs):
	…
	return target_name

def get_task_name(x, **kwargs):
	…
	return task_name

@task(task_run_name=get_task_name,target=get_target_name,checkpoint=True,result=LocalResult())
def task_a(x, y, z):
	…
	return …

Want to check if what I read about orion is accurate... Right now my team runs a bunch of tasks via cron jobs. Would it be possible to start with 2.0 by only using the scheduler aspect? It'd be cool to have a UI for what has run. edit: I don't have experience with 1.0 or 2.0

Hello, signed up for cloud beta but now stuck on the new workspace page. When I am trying to create a new workspace, everything is greyed out. Do I need to complete any additional steps to make this work ?

I've built a flow_of_flows orchestration for my prefect project. Is it possible to see the task dependencies under each nested flow in the UI schematic? Right now I just see 2 flows, but I can't seem to drill down further into each flow

Hi! For Kubernetes agent, is there a way to set environment variables in the Kubernetes jobs that are spun up by prefect agent pod?