Skip to content

Commit 31eccf6

Browse files
committed
Actually save adjusted migration job state
1 parent 32fbd95 commit 31eccf6

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

Refresh.Workers/MigrationJob.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,8 @@ public override void ExecuteJob(WorkContext context)
4747
state.Processed += entitiesLeftCount;
4848
state.Total = state.Total - batch.Length + entitiesLeftCount;
4949
context.Logger.LogInfo(RefreshContext.Database, $"{this.JobId} migrated {batch.Length} objects ({state.Processed}/{state.Total}, complete: {state.Complete})");
50+
51+
context.Database.UpdateOrCreateJobState(this.GetType().Name, state, this.JobClass);
5052
}
5153

5254
protected abstract IQueryable<TEntity> SortAndFilter(IQueryable<TEntity> query);

0 commit comments

Comments
 (0)