allen
06/15/2022, 3:32 PMSandra Youssef
SeungTaeKim
06/16/2022, 5:50 AMflytectl update launchplan -p flytesnacks -d development --version <version> <launchplan name> --archived
David G. Simmons
06/16/2022, 5:49 PMAlex Pozimenko
06/16/2022, 9:26 PMLiang Yao
06/21/2022, 12:32 AMKetan (kumare3)
SeungTaeKim
06/21/2022, 5:39 AMValueError: Type <class 'kirin.api.Kirin'> not supported currently in Flytekit. Please register a new transformer
The above exception was the direct cause of the following exception:
would you give any idea to solve this happening?SeungTaeKim
06/22/2022, 4:20 AMSam
06/22/2022, 7:50 AMGeorge Odette
06/22/2022, 4:03 PMSeungTaeKim
06/23/2022, 8:23 AMCronSchedule
method when I setup launch plan
this is my example of launchplan below.
if __name__ == "__main__":
remote = FlyteRemote(config=Config.auto())
remote.register_launch_plan(
entity=LaunchPlan.get_or_create(
name="daily-test",
workflow=<http://workflows.wf|workflows.wf>,
# Minutes, Hours, Day-of-month, Month, Day-of-week, Year
# minute, hour, day-of-month, month, day-of-week, year
# cron_expression -> aws cron scheme
schedule=CronSchedule(cron_expression="0 3 * * ? *"),
),
project="flytesnacks", #flyte-aistudio
domain="development",
version="51Dwe74FqGRzs2v1WPwrcg==",
)
It returns the error below
launch plan daily failed to update due to rpc error: code = Internal desc = failed adding schedule for unknown schedule expression type &{0 3 * * ? *}
Is this bug fixed to use cron_expression with 6 field type
in the latest version?Kim Junil
06/23/2022, 9:21 AMlaunch plan daily failed to update due to rpc error: code = Internal desc = failed adding schedule for unknown schedule expression type &{0 0 * * ? *}
I found this code in flyteadmin github repo while debugging (https://github.com/flyteorg/flyteadmin/blob/master/scheduler/dbapi/event_scheduler_impl.go)
func (s *eventScheduler) AddSchedule(ctx context.Context, input interfaces.AddScheduleInput) error {
...
switch v := input.ScheduleExpression.GetScheduleExpression().(type) {
case *admin.Schedule_Rate:
fixedRateValue = v.Rate.Value
fixedRateUnit = v.Rate.Unit
case *admin.Schedule_CronSchedule:
cronString = v.CronSchedule.Schedule
default:
return fmt.Errorf("failed adding schedule for unknown schedule expression type %v", v)
}
...
}
and this code in flyteidl repo (https://github.com/flyteorg/flyteidl/blob/master/gen/pb-go/flyteidl/admin/schedule.pb.go)
type Schedule struct {
// Types that are valid to be assigned to ScheduleExpression:
// *Schedule_CronExpression
// *Schedule_Rate
// *Schedule_CronSchedule
ScheduleExpression isSchedule_ScheduleExpression `protobuf_oneof:"ScheduleExpression"`
// Name of the input variable that the kickoff time will be supplied to when the workflow is kicked off.
KickoffTimeInputArg string `protobuf:"bytes,3,opt,name=kickoff_time_input_arg,json=kickoffTimeInputArg,proto3" json:"kickoff_time_input_arg,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
It seems that the error is caused by AddSchedule
function not processing ths Schedule_CronExpression
type.
Can someone help me?Jonathan Lamiel
06/24/2022, 9:23 AMflytectl get execution -p flytesnacks -d development -o json
in the logs or somewhere for post-processing is there a way to do that? (I already have External events configured and processed by a lambda but I missing some context from it)Samhita Alla
Sandra Youssef
Mike Ossareh
06/24/2022, 8:30 PMtyping.List[typing.List[float]]
; it appears to fail to serialize. Is this a known issue / limitation?Sandra Youssef
pyflyte register
and plans for how the pyflyte register, run, package
commands are evolving.
Also, get a preview of the upcoming flyte x ray
and flyte signals
features, as well as the all-new Flyte Airflow Provider!
June 28 at 9 am PT
Calendar invite and Zoom link
See you there!
Flyte TeamVijay Saravana
06/27/2022, 6:15 PMRobert Everson
06/27/2022, 7:23 PMnamespaceTemplate
option for the k8s-array plugin in flytepropeller? We’re on a rather old version, but I’m seeing that flyteadmin is only using the parent namespace for the resources it creates, so when we override the namespaceTemplate
in our clusterresource templates in flyteadmin, we are now seeing an error that the namespace is incorrect (our templates have the namespaceTemplate manually applied to them, so the verification of creating the resource fails as the namespace on the Template and the namespace on the object differ). This might just be an issue with using 2 different versions of flyteadmin and flytepropeller, but wanted to check if this is expected.Robin Kahlow
06/29/2022, 11:06 AMSonja Ericsson
06/29/2022, 12:30 PMKetan (kumare3)
Sandra Youssef
Andrew Achkar
06/30/2022, 3:54 PMFelix Ruess
06/30/2022, 5:06 PMvarsha Parthasarathy
06/30/2022, 6:26 PMflytekit.current_context().execution_id.name or os.environ['FLYTE_INTERNAL_EXECUTION_ID']
Robin Kahlow
07/01/2022, 11:18 AMVijay Saravana
07/02/2022, 5:18 AMSugato Ray
07/02/2022, 10:47 PMflytekit
. But there is no option for opening an issue at the GitHub repository! Seems like you can only open pull requests. Am I missing something?
• https://github.com/flyteorg/flytekit