We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ed4c032 commit bc3dc53Copy full SHA for bc3dc53
pkg/repository/v1/task.go
@@ -292,16 +292,6 @@ func (r *TaskRepositoryImpl) EnsureTablePartitionsExist(ctx context.Context) (bo
292
}
293
294
func (r *TaskRepositoryImpl) UpdateTablePartitions(ctx context.Context) error {
295
- exists, err := r.EnsureTablePartitionsExist(ctx)
296
- if err != nil {
297
- return fmt.Errorf("failed to check if table partitions exist: %w", err)
298
- }
299
-
300
- if exists {
301
- r.l.Debug().Msg("table partitions already exist, skipping")
302
- return nil
303
304
305
const PARTITION_LOCK_OFFSET = 9000000000000000000
306
const partitionLockKey = PARTITION_LOCK_OFFSET + 1
307
0 commit comments