@@ -184,6 +184,7 @@ func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk, _ .
184
184
if err != nil {
185
185
return fmt .Errorf ("error getting workspace %s: %w" , workspaceID , err )
186
186
}
187
+ s .SetProgressOngoing (fmt .Sprintf ("Scanning workspace %s" , workspaceID ), "" )
187
188
if err = s .scanWorkspace (ctx , chunksChan , w ); err != nil {
188
189
return fmt .Errorf ("error scanning workspace %s: %w" , workspaceID , err )
189
190
}
@@ -199,6 +200,7 @@ func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk, _ .
199
200
if err != nil {
200
201
return fmt .Errorf ("error getting collection %s: %w" , collectionID , err )
201
202
}
203
+ s .SetProgressOngoing (fmt .Sprintf ("Scanning collection %s" , collectionID ), "" )
202
204
s .scanCollection (ctx , chunksChan , Metadata {}, collection )
203
205
}
204
206
@@ -209,12 +211,14 @@ func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk, _ .
209
211
return fmt .Errorf ("error enumerating postman workspaces: %w" , err )
210
212
}
211
213
for _ , workspace := range workspaces {
214
+ s .SetProgressOngoing (fmt .Sprintf ("Scanning workspace %s" , workspace .ID ), "" )
212
215
if err = s .scanWorkspace (ctx , chunksChan , workspace ); err != nil {
213
216
return fmt .Errorf ("error scanning workspace %s: %w" , workspace .ID , err )
214
217
}
215
218
}
216
219
}
217
220
221
+ s .SetProgressComplete (1 , 1 , "Completed scanning workspaces" , "" )
218
222
return nil
219
223
}
220
224
0 commit comments