Skip to content

Commit

Permalink
Bugfix on Knative parallel deploy
Browse files Browse the repository at this point in the history
Signed-off-by: Lazar Cvetković <[email protected]>
  • Loading branch information
cvetkovic committed Nov 25, 2024
1 parent 9587658 commit c54df79
Showing 1 changed file with 13 additions and 11 deletions.
24 changes: 13 additions & 11 deletions pkg/driver/deployment/knative.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,17 +53,19 @@ func (*knativeDeployer) Deploy(cfg *config.Configuration) {
deployed.Add(len(cfg.Functions))

for i := 0; i < len(cfg.Functions); i++ {
queue <- struct{}{}

knativeDeploySingleFunction(
cfg.Functions[i],
knativeConfig.YamlPath,
knativeConfig.IsPartiallyPanic,
knativeConfig.EndpointPort,
knativeConfig.AutoscalingMetric,
&deployed,
queue,
)
go func() {
queue <- struct{}{}

knativeDeploySingleFunction(
cfg.Functions[i],
knativeConfig.YamlPath,
knativeConfig.IsPartiallyPanic,
knativeConfig.EndpointPort,
knativeConfig.AutoscalingMetric,
&deployed,
queue,
)
}()
}

deployed.Wait()
Expand Down

0 comments on commit c54df79

Please sign in to comment.