Nail/sless
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(controller): ждать S3Key перед startJobBuild — provider загружает код после создания CRD

Browse Source
This commit is contained in:
Naeel
2026-03-21 06:21:16 +03:00
parent 3b3d510def
commit 735958ba4f
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
controllers/functionjob_controller.go
+8
View File
@@ -112,6 +112,14 @@ func (r *FunctionJobReconciler) Reconcile(ctx context.Context, req ctrl.Request)
// startJobBuild запускает kaniko сборку образа и переводит FunctionJob в фазу Building. // startJobBuild запускает kaniko сборку образа и переводит FunctionJob в фазу Building.
func (r *FunctionJobReconciler) startJobBuild(ctx context.Context, fj *slessv1alpha1.FunctionJob) (ctrl.Result, error) { func (r *FunctionJobReconciler) startJobBuild(ctx context.Context, fj *slessv1alpha1.FunctionJob) (ctrl.Result, error) {
logger := log.FromContext(ctx) logger := log.FromContext(ctx)
// S3Key пустой — код ещё не загружен (provider делает upload после создания CRD).
// Ждём: через 5 секунд provider успеет выполнить UploadJobCode → S3Key заполнится.
if fj.Spec.S3Key == "" {
logger.Info("s3key empty, waiting for code upload", "job", fj.Name)
return ctrl.Result{RequeueAfter: 5 * time.Second}, nil
}
buildJobName, err := r.Builder.Build(ctx, r.OperatorNamespace, fj.Name, fj.Spec.S3Key) buildJobName, err := r.Builder.Build(ctx, r.OperatorNamespace, fj.Name, fj.Spec.S3Key)
if err != nil { if err != nil {
fj.Status.Phase = slessv1alpha1.FunctionJobPhaseFailed fj.Status.Phase = slessv1alpha1.FunctionJobPhaseFailed