Code for task input hash: https://github.com/PrefectHQ/prefect/blob/45609a97988b1d0e17fa3c0bf7d112af76389870/src/prefect/tasks.py#L59

not seeing the slides

103 Lab: • Use a previously made flow • Use Prefect Cloud • Make an email notification automation for flow run completion • Run the flow a few times from the UI CLI • Check out the event feed in the UI • Stretch: create a Slack notification automation

prefect cloud workspace ls

Instructions should say:

Run the flow a few times from the CLI

I'm able to authenticate with Prefect Cloud but running into errors when running the flow.

prefect profile create local

How to find slack webhook URL?

Is there a slack webhook we should use?

beat me to it

This helped -> https://discourse.prefect.io/t/how-to-create-a-slack-webhook-url-for-the-slackwebhook-notification-block-incoming-webhook/2260

Here is some additional documentation for profiles

Hi ! Can anyone help in use webhook block ? we're trying to make it workable for discord webhook

I have loaded

webhook_block = Webhook.load("discord-hook")

but not sure how to go further

it looks like async functionhttps://docs.prefect.io/2.10.13/api-ref/prefect/blocks/webhook/#prefect.blocks.webhook.Webhook

Have a good break everyone! We’ll see you at 3pm ET! 🎉

was able to get

email

via automation and discord via code itself

from prefect import flow,task,get_run_logger
import httpx
from prefect.tasks import task_input_hash
from datetime import timedelta
from prefect.blocks.webhook import Webhook
import json
webhook_url = "<https://discord.com/api/webhooks/1118608415695065140/3HM_Z9wtiruGWQhlXZFEYF7kZNP8Wh1qEk2E7HiEx5KblwCM8WVAsQQ_DgTPr8JwJFK7>"



# API to hit - <https://api.open-meteo.com/v1/forecast?latitude=52.52&longitude=13.41&hourly=weathercode,windspeed_10m,soil_temperature_0cm>

@task(retries=2)
def get_windspeed_10m(lat,lon):
    logger = get_run_logger()
    r = httpx.get(f'<https://api.open-meteo.com/v1/forecast?latitude={lat}&longitude={lon}&hourly=windspeed_10m&forecast_days=1>')
    <http://logger.info|logger.info>('HEYYYIOO, the code is %s', r.status_code)
    if r.status_code >= 400:
        raise Exception("bad requw")
    wind_speed = r.json()['hourly']['windspeed_10m'][0]
    return wind_speed

@task(cache_key_fn=task_input_hash, cache_expiration=timedelta(seconds=30))
def get_windspeed_80m(lat,lon):
    r = httpx.get(f'<https://api.open-meteo.com/v1/forecast?latitude={lat}&longitude={lon}&hourly=windspeed_80m&forecast_days=1>')
    wind_speed = r.json()['hourly']['windspeed_80m'][0]
    return wind_speed

@flow()
def get_weather(lat,lon):
    
    wind_speed_80 = get_windspeed_80m(lat,lon) 
    wind_speed = get_windspeed_10m(lat,lon)
    wind_speed_fasttt = wind_speed_80 * 2
    return {
        "wind_speed_80m" :wind_speed_80,
        "wind_speed_10m" :wind_speed,
        "wind_speed_fasttt" :wind_speed_fasttt,
    }


@task
def get_soil_temperature_0cm(lat,lon):
    r = httpx.get(f'<https://api.open-meteo.com/v1/forecast?latitude={lat}&longitude={lon}&hourly=soil_temperature_0cm&forecast_days=1>')
    soil_temp = r.json()['hourly']['soil_temperature_0cm'][0]
    return soil_temp

@flow(log_prints=True, name='my_weather_flow_faster_no_cache_16')
def get_all(lat,lon):
    # obj = get_weather(lat,lon)
    soil_temp = get_soil_temperature_0cm(lat,lon)
    print({
        # "wind_10m" : obj['wind_speed_10m'],
        # "wind_80m" :obj['wind_speed_80m'],
        # "wind_speed_fasttt" :obj['wind_speed_fasttt'],
        "soil_temp" :soil_temp,
    })
    # webhook_block = Webhook.load("discord-hook")
    send_notif('flow is flown :P ')


def send_notif(text):
    message = {
    "content":text  # Message content
}
    payload = json.dumps(message)

# Set the headers for the request
    headers = {
        "Content-Type": "application/json"
    }

    # Send the POST request to the webhook URL with the payload and headers
    response = <http://httpx.post|httpx.post>(webhook_url, data=payload, headers=headers)

    # Check the response status code to see if the message was sent successfully
    if response.status_code == 204:
        print("Message sent successfully!")
    else:
        print("Failed to send message. Response status code:", response.status_code)
        
if __name__  == '__main__' :
    get_all(52,16)

is there documentation on how the email JSON block should be structured?

I need to step out for an urgent call v sorry

How can we pass parameters in

prefect deploy flowtest.py:get_all

command , where

get_all

is my flow and it needs params

Work Pools: https://docs.prefect.io/2.10.13/concepts/work-pools/#work-queues

104 Lab Instructions: Use a flow from the 103 lab • Make a deployment via interactive CLI commands • Start a worker • Run a deployment from the UI • Check out the deployment and flow run in the UI • Create a deployment that has default parameters • Override the default parameters at runtime in the UI

I keep hitting the "AttributeError" upon trying to deploy a flow using "prefect deploy"

File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\cli\deploy.py", line 391, in _run_single_deploy

flow_name = flow.name

AttributeError: 'NoneType' object has no attribute 'name'

An exception occurred.

For the first step, do we need to update to a newer version of Prefect? Currently I'm running 2.10.13 I'm not seeing the interactive CLI

I'm running

prefect deploy .\flow.py:my_flow

I'm did a quick run but it's status is late 🤔

Let’s get back together in 5 minutes, at 4pm ET. Take a quick break if you need to prior!

Give me a 👍 if you got a deployment running!

(prefect) λ prefect deploy flows.py:pipe Traceback (most recent call last): File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\cli\_utilities.py", line 41, in wrapper return fn(*args, **kwargs) File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\utilities\asyncutils.py", line 255, in coroutine_wrapper return call() File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\_internal\concurrency\calls.py", line 383, in call return self.result() File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\_internal\concurrency\calls.py", line 283, in result return self.future.result(timeout=timeout) File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\_internal\concurrency\calls.py", line 169, in result return self.__get_result() File "D:\Packages\Miniconda\envs\prefect\lib\concurrent\futures\_base.py", line 403, in __get_result raise self._exception File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\_internal\concurrency\calls.py", line 346, in _run_async result = await coro File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\cli\deploy.py", line 300, in deploy await _run_single_deploy( File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\client\utilities.py", line 40, in with_injected_client return await fn(*args, **kwargs) File "D:\Packages\Miniconda\envs\prefect\lib\site-packages\prefect\cli\deploy.py", line 391, in _run_single_deploy flow_name = flow.name AttributeError: 'NoneType' object has no attribute 'name' An exception occurred.

❓ What does it mean if we did a Quick Run in the UI from a deployment and the run is

late

?