Method LoadFromLocal

modules/backendscheduler/work/work.go:160–184

LoadFromLocal reads the work cache from local storage using sharding approach

(_ context.Context, localPath string)

// LoadFromLocal reads the work cache from local storage using sharding approach
func (w *Work) LoadFromLocal(_ context.Context, localPath string) error {
	w.mtx.Lock()
	defer w.mtx.Unlock()

	// Load from shard files - BackendScheduler already determined this is the right approach
	for i := range ShardCount {
		shardPath := filepath.Join(localPath, FileNameForShard(uint8(i)))

		data, err := os.ReadFile(shardPath)
		if err != nil {
			if os.IsNotExist(err) {
				continue // Empty shard is OK
			}
			return err
		}

		err = w.UnmarshalShard(i, data)
		if err != nil {
			return err
		}
	}

	w.rebuildPendingIndexes()
	return nil
}

// StartJob starts a job in the appropriate shard
func (w *Work) StartJob(id string) {