prefect-community #prefect-server

[linuxserver02 ~]$ prefect auth login -t <copied token> Usage: prefect auth [OPTIONS] COMMAND [ARGS]... Error: Auth commands with server are not currently supported.

Michael J Hall

09/13/2020, 2:21 PM

I am attempting this from where Prefect server is configured, in this case our RHEL Linux server.

Michael J Hall

09/13/2020, 2:23 PM

Switching to the prefect backend cloud worked. Thanks.

Michael J Hall

09/13/2020, 3:03 PM

Walking through the tutorial on getting my first flow to run. Do I put the sample write flow code into a python script and run it using python3.6?

Michael J Hall

09/13/2020, 3:04 PM

https://docs.prefect.io/orchestration/tutorial/first.html#write-flow

Michael J Hall

09/13/2020, 4:09 PM

Getting this error while attempting to import prefect in Python3.6: "TomlDecodeError: invalid literal for int() with base 0: 'abcabcxyzxyz123123' (line 5 column 1 char 66)"

Michael J Hall

09/13/2020, 4:19 PM

I think it has something to do with the cloud agent auth token

Michael J Hall

09/13/2020, 8:31 PM

After I generated the cloud agent the second time, it appears have taken hold and I can import prefect in Python3.6. However when I run the sample code I am getting this error:

Michael J Hall

09/13/2020, 8:31 PM

Copy code

[linuxserver02 ~]$ prefect backend cloud
Backend switched to cloud
[linuxserver02 ~]$ export PREFECT__CLOUD__AGENT__AUTH_TOKEN=ABC123ABC123123XYZ
[linuxserver02 ~]$ python3.6
Python 3.6.8 (default, Jun 11 2019, 15:15:01)
[GCC 4.8.5 20150623 (Red Hat 4.8.5-39)] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> import prefect
>>> from prefect import task, Flow
>>>
>>> @task
... def hello_task():
...     logger = prefect.context.get("logger")
...     <http://logger.info|logger.info>("Hello, Cloud!")
...
>>> flow = Flow("hello-flow", tasks=[hello_task])
>>> flow.register(project_name="Hello, World!")
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/local/lib/python3.6/site-packages/prefect/core/flow.py", line 1594, in register
    no_url=no_url,
  File "/usr/local/lib/python3.6/site-packages/prefect/client/client.py", line 730, in register
    project_name, project_name
ValueError: Project Hello, World! not found. Run `client.create_project("Hello, World!")` to create it.
>>>

Michael J Hall

09/13/2020, 8:32 PM

Can anyone suggest what may be happening here?

sark

09/14/2020, 3:52 AM

hi guys is my understanding correct that for

LocalStorage

it is local to the machine registering the flow, but for

LocalEnvironment

it is local to the the machine of the agent?

sark

09/14/2020, 3:56 AM

also i am registering my flows from a machine separate to the server and to whatever will run my flows, i hope this is not a anti-pattern

Hagai Arad

09/14/2020, 8:00 AM

Hi, I’m new to Prefect so maybe my question is dumb (hopes not 😅). How can I add to my flow an execution of .py files that are stored on Github or on my machine? The meaning is how to run code that is external to the flow I registered. I currently have everything running locally (I ran prefect backend server and prefect server start) and I successfully run simple flows. Thanks!

Juan

09/14/2020, 8:17 AM

Hi, my prefect server is receiving flows and the GUI shows them as scheduled although in vscode I see them as finished. Does somebody know something about this behavior ?

Rizky Eko Putra

09/14/2020, 9:11 AM

Hello, anyone know what should I do with this error

Copy code

/usr/local/lib/python3.7/site-packages/prefect/core/flow.py:1594: UserWarning: No result handler was specified on your Flow. Cloud features such as input caching and resuming task runs from failure may not work properly.
  no_url=no_url,

Ian Fridge

09/15/2020, 6:45 PM

Hi. Is there a recommended git ops workflow best practice for teams which don't want developers to directly submit flows with an agent?

Charles Leung

09/15/2020, 8:59 PM

Hey prefect team, does prefect work on windows? how about local agent / docker agent?

Chandra Manginipalli

09/16/2020, 8:46 PM

Is it possible to start the prefect server at a port different from 8080? It appears the port 8080 is taken

sebastian.clanzett

09/17/2020, 4:25 PM

if i try to connect to a local prefect server with a prefect agent inside a docker container by using: prefect agent start --api http://192.168.1.1:4200/graphql, no flow gets deployed to the server. is there anything i am missing?

Nils Israel

09/17/2020, 5:09 PM

Hi, I am having a problem installing prefect server on Ubuntu 20.04. The UI can't connect to the backend. I tried the hello using curl and got a response. But the default connect to http://localhost:4200/graphql isn't working. Can someone help?

Chandra Manginipalli

09/17/2020, 6:12 PM

When I stop my prefect local server and restart, the flows I registered (and projects created) are gone. Are they not persisted in the backend like the cloud?

matt forbes

09/17/2020, 7:24 PM

has anyone had success running prefect server on kubernetes directly (rather than docker-compose)?

Chandra Manginipalli

09/17/2020, 7:46 PM

Is there a way to run the prefect agent in detached mode like this. Just so if shell is closed the agent continues to run? That way I can run the flows on a local server.

👀 1

Dave

09/18/2020, 10:39 AM

Hi, Is it correct that we aren't able to set an interval lower than one minute if you're running Prefect Core? I just tried to register a flow and got the following:

"Interval can not be less than one minute when deploying to Prefect Cloud."

I'm running the latest version of Prefect.

Vipul

09/18/2020, 11:33 AM

I am having issue while running with Flow within Flow which has Parameter that are determined at run time.

Copy code

with Flow("MasterFlow") as master_flow:
    cobdate = Parameter("cobdate")
    staging_area = FlowRunTask(flow_name='staging_area',
                               parameters=dict(cobdate=cobdate),
                               project_name="SubFlow")
    business_logic_layer = FlowRunTask(flow_name='business_logic_layer',
                                       project_name="SubFlow")
    data_mart = FlowRunTask(flow_name='data_mart',
                            project_name="SubFlow",
                            wait=True)
    staging_area.set_downstream(data_mart)
    business_logic_layer.set_downstream(data_mart)

Vipul

09/18/2020, 11:35 AM

Sorry, pressed enter too early. The issue I am seeing is that • From UI, when I run MasterFlow, it does not give me an option to populate cobdate