Quinn Romanek
01/24/2022, 11:45 PMflytectl register files
first?Ketan (kumare3)
Quinn Romanek
01/25/2022, 12:00 AMKetan (kumare3)
Quinn Romanek
01/25/2022, 12:00 AMKetan (kumare3)
Quinn Romanek
01/25/2022, 12:01 AMKetan (kumare3)
Quinn Romanek
01/25/2022, 12:59 AMKetan (kumare3)
katrina
Prafulla Mahindrakar
01/26/2022, 5:35 PMQuinn Romanek
01/26/2022, 6:17 PMfrom flytekit import CronSchedule, LaunchPlan, Email, WorkflowExecutionPhase
from flyte.workflows import nba
# Run daily download at 10 am every day
daily_download_lp = LaunchPlan.get_or_create(
name="daily_download_schedule",
workflow=nba.daily_download,
schedule=CronSchedule(schedule="0 10 * * *"),
notifications=[
Email(
phases=[
WorkflowExecutionPhase.FAILED,
WorkflowExecutionPhase.SUCCEEDED,
WorkflowExecutionPhase.TIMED_OUT,
],
recipients_email=["xxxx"],
)
],
)
flytectl update launchplan \
-c config.yaml \
-p quinnba \
-d development \
daily_download_schedule \
--version 08b064a7 --activate
Prafulla Mahindrakar
01/26/2022, 7:19 PMQuinn Romanek
01/26/2022, 7:31 PM