disable resource filtering on scheduler.
This commit is contained in:
parent
b7a5e3cd0f
commit
4fcd0b7aca
@ -128,7 +128,7 @@ func TestQuotePriceForUnsealedRetrieval(t *testing.T) {
|
|||||||
|
|
||||||
kit.QuietMiningLogs()
|
kit.QuietMiningLogs()
|
||||||
|
|
||||||
client, miner, ens := kit.EnsembleMinimal(t, kit.MockProofs())
|
client, miner, ens := kit.EnsembleMinimal(t)
|
||||||
ens.InterconnectAll().BeginMining(blocktime)
|
ens.InterconnectAll().BeginMining(blocktime)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -444,10 +444,10 @@ func (n *Ensemble) Start() *Ensemble {
|
|||||||
|
|
||||||
// disable resource filtering so that local worker gets assigned tasks
|
// disable resource filtering so that local worker gets assigned tasks
|
||||||
// regardless of system pressure.
|
// regardless of system pressure.
|
||||||
node.Override(new(*sectorstorage.SealerConfig), func() *sectorstorage.SealerConfig {
|
node.Override(new(sectorstorage.SealerConfig), func() sectorstorage.SealerConfig {
|
||||||
scfg := config.DefaultStorageMiner()
|
scfg := config.DefaultStorageMiner()
|
||||||
scfg.Storage.ResourceFiltering = sectorstorage.ResourceFilteringDisabled
|
scfg.Storage.ResourceFiltering = sectorstorage.ResourceFilteringDisabled
|
||||||
return &scfg.Storage
|
return scfg.Storage
|
||||||
}),
|
}),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user