diff --git a/models/workflow_execution/workflow_scheduler.go b/models/workflow_execution/workflow_scheduler.go index d32fd49..0f314b1 100644 --- a/models/workflow_execution/workflow_scheduler.go +++ b/models/workflow_execution/workflow_scheduler.go @@ -6,6 +6,7 @@ import ( "strings" "time" + "cloud.o-forge.io/core/oc-lib/logs" "cloud.o-forge.io/core/oc-lib/models/booking" "cloud.o-forge.io/core/oc-lib/models/common/enum" "cloud.o-forge.io/core/oc-lib/models/peer" @@ -112,6 +113,8 @@ func (ws *WorkflowSchedule) Schedules(wfID string, request *tools.APIRequest) (* } ws.Workflow = wf for _, booking := range bookings { + l := logs.GetLogger() + l.Info().Msg("Booking on " + booking.DestPeerID) _, err := (&peer.Peer{}).LaunchPeerExecution(booking.DestPeerID, "", tools.BOOKING, tools.POST, booking.Serialize(booking), request.Caller) if err != nil {