@@ -133,7 +133,7 @@ func (pp *PipelinesProvider) createLocalPACResources(ctx context.Context, f fn.F
133
133
// also creates PVC for the function source code
134
134
func (pp * PipelinesProvider ) createClusterPACResources (ctx context.Context , f fn.Function , metadata pipelines.PacMetadata ) error {
135
135
// figure out pac installation namespace
136
- installed , _ , err := pac .DetectPACInstallation (ctx , "" )
136
+ installed , _ , err := pac .DetectPACInstallation (ctx , "openshift-pipelines " )
137
137
if ! installed {
138
138
errMsg := ""
139
139
if err != nil {
@@ -154,7 +154,12 @@ func (pp *PipelinesProvider) createClusterPACResources(ctx context.Context, f fn
154
154
labels = pp .decorator .UpdateLabels (f , labels )
155
155
}
156
156
157
- registry , err := docker .GetRegistry (f .Image )
157
+ img := f .Deploy .Image
158
+ if img == "" {
159
+ img = f .Image
160
+ }
161
+
162
+ registry , err := docker .GetRegistry (img )
158
163
if err != nil {
159
164
return fmt .Errorf ("problem in resolving image registry name: %w" , err )
160
165
}
@@ -163,7 +168,7 @@ func (pp *PipelinesProvider) createClusterPACResources(ctx context.Context, f fn
163
168
registry = authn .DefaultAuthKey
164
169
}
165
170
166
- creds , err := pp .credentialsProvider (ctx , f . Image )
171
+ creds , err := pp .credentialsProvider (ctx , img )
167
172
if err != nil {
168
173
return err
169
174
}
@@ -199,7 +204,7 @@ func (pp *PipelinesProvider) createClusterPACResources(ctx context.Context, f fn
199
204
func (pp * PipelinesProvider ) createRemotePACResources (ctx context.Context , f fn.Function , metadata pipelines.PacMetadata ) error {
200
205
201
206
// figure out pac installation namespace
202
- installed , installationNS , err := pac .DetectPACInstallation (ctx , "" )
207
+ installed , installationNS , err := pac .DetectPACInstallation (ctx , "openshift-pipelines " )
203
208
if ! installed {
204
209
errMsg := ""
205
210
if err != nil {
0 commit comments