diff --git a/graph/db/sql_migration.go b/graph/db/sql_migration.go index 8a529765b..0b06e7cac 100644 --- a/graph/db/sql_migration.go +++ b/graph/db/sql_migration.go @@ -410,6 +410,8 @@ func migrateChannelsAndPolicies(ctx context.Context, kvBackend kvdb.Backend, } channelCount++ + chunk++ + err = migrateSingleChannel( ctx, sqlDB, channel, policy1, policy2, migChanPolicy, )