FWIW, I followed the instructions on the Cloud dashboard. Effectively something like auth, create a .py script and its flow.serve. The issue here is that the script is running. I see it on Cloud, but if I ctrl+C locally, things are impacted. Trying to build intuition because clearly this can't be a way teams push from local to Cloud.

I got something working, and things make a lot more sense to me now, so logging here in case it helps someone else. 1. After creating an example flow, I used

prefect deploy

which opens a pretty slick CLI tool. 2. I followed the options and selected the basics a. My defined flow. It even found this in a nested

/flows

folder b. Left the name default c. configure schedules -> i. Kinda odd because I defined this in the script (below). I see what the CLI is doing now, but basically I am still not sure why I would ever set it in the py file. ii. selected CRON and moved on d. activated the schedule when prompted e. created a worker pool and gave a name f. infra type -> prefect managed g. Remote storage, no as this is found on my local machine h. save config -> yes The last step above is where my 💡 went off. The YAML file shows why those options matter and now that I see the resource on Prefect Cloud, dots are coming together around ways to store your flows or the level of control you have over the worker pool.

from prefect import flow


@flow(log_prints=True)
def hello_world(name: str = "world", goodbye: bool = False):
    print(f"Hello {name} from Prefect! 🤗")

    if goodbye:
        print(f"Goodbye {name}!")


if __name__ == "__main__":
    hello_world.deploy(
        name="my-first-deployment",
        cron="15 0 * * *"
    )

In the end, some things were not obvious (to me) and only really started to make sense relative to the docs after stumbling across the CLI flow, which is fantastic. hattip

However, I can't seem to get a trigger of the flow to run successfully. I am getting crashed errors in the log. Kinda stumped. When I run

python myfile.py

it logs successfully in cloud. Need to put this aside, but I am missing something about the free tier and worker pools.

1. Kinda odd because I defined this in the script (below). I see what the CLI is doing now, but basically I am still not sure why I would ever set it in the py file.

In short, you came across two ways of scheduling a deployed flow (through the CLI using

prefect deploy

, and

.deploy()

which uses the python SDK). You really only had to do one or the other, as they can both be used to: 1) create a scheduled deployment and 2) assign work to a work pool.

If you wouldn't mind sharing your error from the logs, we'll help you get to the next step.

And to be more specific, I am getting "Crashed" with

Reported flow run '20480205-73a3-458f-b5b7-e7d4b072b10e' as crashed: Flow run process exited with non-zero status code 1.

As noted above, I now wonder if its because I am pointing to a local source and not, say a public github repo. In practice I wouldn't want anything public, but for the course, this is fine.

To come back to this, I just created a new deployment with a very simple flow found on a public git repo and it is still crashing. I figured my issue was that I wasn't pointing to a public source to pull from. Completely stumped @Nate @Bianca Hoch This is the function: https://github.com/Btibert3/BA882-Fall24-InClass-Project/blob/main/prefect/sandbox/hello-world.py My yaml for deployment

# Welcome to your prefect.yaml file! You can use this file for storing and managing
# configuration for deploying your flows. We recommend committing this file to source
# control along with your flow code.

# Generic metadata about this project
name: prefect
prefect-version: 3.0.4

# build section allows you to manage and build docker images
build: null

# push section allows you to manage if and how this project is uploaded to remote locations
push: null

# pull section allows you to provide instructions for cloning this project in remote locations
pull:
- prefect.deployments.steps.git_clone:
    repository: <https://github.com/Btibert3/BA882-Fall24-InClass-Project.git>
    branch: main

# the deployments section allows you to provide configuration for deploying flows
deployments:
- name: hello-world
  version: null
  tags: []
  concurrency_limit: null
  description: null
  entrypoint: sandbox/hello-world.py:simple_flow
  parameters: {}
  work_pool:
    name: brock-worker1
    work_queue_name: null
    job_variables: {}
  enforce_parameter_schema: true
  schedules:
  - cron: 0 0 * * *
    timezone: UTC
    day_or: true
    active: true
    max_active_runs: null
    catchup: false

Clearly I am missing something obvious or silly, but now that I am using pull from a public project, I have zero idea why its crashing.

if you look at your worker logs, I imagine you'd see some

FileNotFoundError

This is the page I am going off of: https://docs.prefect.io/3.0/deploy/infrastructure-examples/managed