Hello! How do I access the string value in a Parameter object? I'm passing a string Parameter to a flow throw the CLI as 

prefect run --watch --id flowId --param strparam="paramValue"

 . Then in the flow.py file, I am initializing outside the flow 

strparam = Parameter("strparam", default "hello")

  but I'm unable to access 

"paramValue"

 . Prefect only sees this 

<Parameter: strparam>

Good morning everyone, I would like to know a really basic thing with Docker Agents. I have created a DockerAgent with all the necessary libraries which are needed for the flow to run. And then I started the Docker Agent using a docker-compose file. I can see the below logs:

[2022-03-03 05:10:35,310] INFO - TranslationEvaluator Agent | Registering agent...
[2022-03-03 05:10:36,108] INFO - TranslationEvaluator Agent | Registration successful!
[2022-03-03 05:10:36,498] INFO - TranslationEvaluator Agent | Starting DockerAgent with labels ['On_Prem_Agent', 'IP:<>']

[2022-03-03 05:10:36,498] INFO - TranslationEvaluator Agent | Agent documentation can be found at <https://docs.prefect.io/orchestration/>

[2022-03-03 05:10:36,498] INFO - TranslationEvaluator Agent | Waiting for flow runs...

I then went and created a Flow and registered the flow as a docker. But when I try to run the flow from the prefectUI, the flow starts running and I see the below lines in the log of the DockerAgent:

[2022-03-03 05:20:32,889] INFO - TranslationEvaluator Agent | Deploying flow run 9cf17c39-877c-49e7-aae4-0451e320bae4 to execution environment...

/usr/local/lib/python3.7/dist-packages/prefect/agent/docker/agent.py:151: UserWarning: DockerAgent `docker_interface` argument is deprecated and will be removed from Prefect. Setting it has no effect.

  UserWarning,

[2022-03-03 05:20:33,579] INFO - TranslationEvaluator Agent | Completed deployment of flow run 9cf17c39-877c-49e7-aae4-0451e320bae4

[2022-03-03 05:20:34+0000] INFO - prefect.CloudFlowRunner | Beginning Flow run for 'On_Prem_Agent'

But it fails, with some libraries are missing to do the logic in one of the tasks in the flow. I am under the impression that the agent I created needs to have all the libraries installed and the flow just run on the agent using them. What is the right way to do this, so that I can get this working. Thanks, Sen

Docks prefect give Internal Server Error - Request ID: 01FXQBPXZ25Q9W9CNRZW0A1A37

I am looking for a hotswappable 65% keyboard with rgb. Any suggestions out there?

I just would like to give my appreciation for this platform and community. Unfortunately in a while I'll have to change platform, but this platform and community have been everything I could've asked for and more.

I'm not sure where to post this feedback, so I'll try here. I'm reading through the Prefect Orion docs, and on the Flow and task configuration page, the Orchestration Policies link under Additional Reading returns a 404 not found error.

Is there a prefect 2.0 slack channel?

is there a pandas community channel?

I have a Prefect joke, but it’s “Scheduled”.

Anyone going to PyCon next month?

The flow-run naming generator [adjective]-[animal] really tricked me today! 🤣🤣🤣

Hi community, does anyone have a cool Prefect + Great Expectations use case? Looking for an example to include in a blog.

Any recommendations on migrations tools? I'm using sqlalchemy but not a fan of Alembic.

Does Pandas have a bulk update(not insert) functionality with sqlalchemy?

Hi! Thanks for Prefect! I was wondering when we could expect map support in Prefect 2? No worries if this can't be answered. Just curious!

Hi there, I have a local prefect set up thas was running with no error until today. The workflows run in a "local" agent inside a docker container. Today I start to get the error

ModuleNotFoundError: No module named '/root/'

(trackback is on the thread) If I access the agent container and run any flow manually (

python workflows/ad_check/flow.py

) it works! Can someone help me?

Hello, I have an issue with the

DaskTaskRunner

. Somehow it gets stuck on the last task and will not finish. This is my minimum example:

from prefect import task, flow 
from prefect.tasks import task_input_hash 
import time 
from prefect.task_runners import SequentialTaskRunner, DaskTaskRunner 
 
@task 
def list_files(): 
   return ["1.txt", "2.txt"] 
 
@task 
def preprocess(in_file: str, target_dir: str): 
   time.sleep(1) 
   return f"{target_dir}-{in_file}" 
 
@task 
def segment(in_file: str, target_dir: str): 
   return f"{target_dir}-{in_file}" 
 
@task 
def mask_bg(in_file: str, mask: str, target_dir: str): 
   return f"{target_dir}-mask-{in_file}" 
 
@flow(name="Background Masking", task_runner=DaskTaskRunner()) 
def background_masking(): 
   files = list_files() 
   preprocessed = [] 
   segmented = [] 
   masked = [] 
   for f in files.wait().result(): 
       preprocessed.append(preprocess(f, target_dir="/preprocessed/")) 
       segmented.append(segment(preprocessed[-1], target_dir="/segmented/")) 
       masked.append(mask_bg(preprocessed[-1], segmented[-1], target_dir="/masked/")) 
        
if __name__ == "__main__": 
   result = background_masking()

If I run this locally (no remote file storage) with normal sqlite-db the processing does not finish. With

SequentialTaskRunner

or

ConcurrentTaskRunner

the script completes.

How much does it usually take Sales to reach a person, who is interested in buying Cloud version?

Hi, I want to acheive a flow where i can controll a task in running flow, actually my problem statement is like event based, for me its like when a event will start it will have some timeout time and if the event completes before that timeout then i should move to next task

I apologize if this has been asked before. Is there any way that I can return a dictionary from one Task and use it as the input kwargs for another task? More specifically I want a task that returns a Dictionary and I want to pass its result to another task using variable unpacking...

dict_result = some_task()

some_other_task(**dict_result)

Is this doable? Is there a more Prefect-y way to accomplish this without creating a Parameter for eahc element of the dictionary? I ultimately want to pass as an input a list of dictionaries which I can then operate over using Prefect's mapping, so being able to define the collection of arguments together is important.

This might be random, but I understand the use of Prefect for developing/orchestrating data pipelines for data analytics/reporting. Do people also use Prefect (or open source in general) for Enterprise application/information/system integration (essentially synchronizing information between two operational systems)? When I try to research this topic all I can find are advertisements from PaaS/SaaS companies trying to sell their all-in-one solutions.

I posted before but noone really responded. Anyone going to PyCon next week? 😛ython:

Hi everyone, happy Friday! We're gonna post programmer jokes and memes every Friday - starting today! :catjam: If you want to join us in this madness, feel free to post something, too! Have a great weekend! :marvin:

All I can do is put on a brave face and learn from @Laurie Hindes

Hi peeps 👋 At my company we're trying to improve the data quality of our (Databricks) Delta Lake by introducing monitoring. We'd like to add assertions (as SQL statements) that we could then schedule and alert on (based on the query results). Any of you familiar with such tools that you could recommend❓ Databricks has its own thing called SQL analytics but unfortunately it doesn't have any form of git integration