run_deployment

# prefect version
23:39:04.743 | DEBUG   | prefect.client - Connecting to API at <https://api.prefect.cloud/api/accounts/57e0246d-d752-4737-b29a-192e8f6eb886/workspaces/6d439078-f534-4a0a-89e0-9c4ced644d6a/>
Version:             2.5.0
API version:         0.8.2
Python version:      3.8.16
Git commit:          eac37918
Built:               Thu, Oct 6, 2022 12:41 PM
OS/Arch:             linux/aarch64
Profile:             default
Server type:         cloud

@flow(flow_run_name='testing123')
TypeError: flow() got an unexpected keyword argument 'flow_run_name'

prefect.exceptions.PrefectHTTPStatusError: Server error '500 Internal Server Error' for url '<https://api.prefect.cloud/api/accounts/5626ffe9-0140-4e88-babc-4a4fc614bb99/workspaces/ee8a533d-2754-420e-87f2-2d6b084984af/flow_runs/>'
Response: {'exception_message': 'Internal Server Error'}
For more information check: <https://httpstatuses.com/500>

from zoneinfo import ZoneInfo
from dateutil.rrule import MINUTELY, rrule
from prefect import flow
from prefect.deployments import Deployment
from prefect.server.schemas.schedules import RRuleSchedule

london = ZoneInfo("Europe/London")

@flow
def some_flow():
    print("whoa")

Deployment.build_from_flow(
    flow=some_flow, 
    schedule=RRuleSchedule.from_rrule(
        rrule(
            freq=MINUTELY,
            interval=10,
            dtstart=dt(2020, 1, 1, tzinfo=london),
            byhour=range(8, 9),
        )
    ),
)

schedule=RRuleSchedule.from_rrule(
  File "/Users/sh/Projects/flows/.venv/lib/python3.9/site-packages/prefect/server/schemas/schedules.py", line 410, in from_rrule
    timezone = rrule._dtstart.tzinfo.name
AttributeError: 'zoneinfo.ZoneInfo' object has no attribute 'name'

from datetime import timezone

prefect.settings.PREFECT_API_URL

os.environ

flows

skip_upload

Unhealthy

validate=False

prefect\client\base.py", line 130, in raise_for_status
    raise PrefectHTTPStatusError.from_httpx_error(exc) from exc.__cause__
prefect.exceptions.PrefectHTTPStatusError: Server error '502 Bad Gateway' for url
'<https://api.prefect.cloud/api/accounts/xxxxx/flow_runs/filter>'
For more information check: <https://httpstatuses.com/502> 
Agent stopped!

"data": {
    "type": "reference",
    "serializer_type": "compressed/json",
    "storage_block_id": "e3311389-34e1-491c-aaef-cbcf6e6ea977",
    "storage_key": "e4940b1d2ada42a7a1ac77710cae4d18"
  },

10:44:28.065 | WARNING | Task run 'email_send_message-357' - Task run '52fa4b9c-deb0-407c-a992-ccde4685dfcd' received abort during orchestration: The enclosing flow must be running to begin task execution. Task run is in PENDING state.

prefect.exceptions.MissingResult: State data is missing. Typically, this occurs when result persistence is disabled and the state has been retrieved from the API.

persist_result=True

humana_smtp = EmailServerCredentials.load("some-smtp-server")
for email in emails:
    email_send_message.submit(
        subject=email.subject,
        msg=email.rendered_html_template,
        email_server_credentials=humana_smtp,
        email_from=email.email_from,
        email_to=<http://email.to|email.to>,
        email_to_cc=<http://email.cc|email.cc>,
        email_to_bcc=email.bcc,
        attachments=email.attachments,
        images=email.images,
        dry_run=dry_run,
    )

email_chunks_for_sending = chunkify(emails, 50)
humana_smtp = EmailServerCredentials.load("some-smtp-server")
for chunk in email_chunks_for_sending:
    wait_for_complete_object = []
    for email in chunk:
        sent = email_send_message.submit(
            subject=email.subject,
            msg=email.rendered_html_template,
            email_server_credentials=humana_smtp,
            email_from=email.email_from,
            email_to=<http://email.to|email.to>,
            email_to_cc=<http://email.cc|email.cc>,
            email_to_bcc=email.bcc,
            attachments=email.attachments,
            images=email.images,
            dry_run=dry_run,
        )
        wait_for_complete_object.append(sent)
    [future.result() for future in wait_for_complete_object]

def chunkify(xs, size):

    return (xs[pos : pos + size] for pos in range(0, len(xs), size))

KubernetesJob

Prefect 2.0

#!/bin/bash
eval "$(conda shell.bash hook)"
conda activate ETL
prefect server start

[Unit]
Description=Prefect

[Service]
Type=simple
ExecStart=/home/zeephremia/files_required/initate.sh
User=root
Group=root

[Install]
WantedBy=multi-user.target

prefect_service.service - Prefect
     Loaded: loaded (/etc/systemd/system/prefect_service.service; enabled; vendor preset: enabled)
     Active: inactive (dead) since Thu 2023-02-23 23:29:43 UTC; 3s ago
    Process: 2233 ExecStart=/home/zeephremia/files_required/initate.sh (code=exited, status=0/SUCCESS)
   Main PID: 2233 (code=exited, status=0/SUCCESS)

Feb 23 23:29:43 linux-server systemd[1]: Started Prefect.
Feb 23 23:29:43 linux-server initate.sh[2233]: Starting the script...
Feb 23 23:29:43 linux-server initate.sh[2234]: /home/zeephremia/files_required/initate.sh: line 5: conda: command not found
Feb 23 23:29:43 linux-server initate.sh[2235]: /home/zeephremia/files_required/initate.sh: line 6: conda: command not found
Feb 23 23:29:43 linux-server initate.sh[2237]: /home/zeephremia/files_required/initate.sh: line 7: prefect: command not found
Feb 23 23:29:43 linux-server initate.sh[2233]: Script completed.
Feb 23 23:29:43 linux-server systemd[1]: prefect_service.service: Succeeded.