@@ -89,7 +89,6 @@ func (tce *testConflictError) IsConflictError() bool {
89
89
90
90
func TestUnfilledBatch (t * testing.T ) {
91
91
log .SetLevel ("debug" )
92
- coreconfig .Reset ()
93
92
94
93
dispatched := make (chan * DispatchPayload )
95
94
cancel , mdi , bp := newTestBatchProcessor (t , func (c context.Context , state * DispatchPayload ) error {
@@ -154,7 +153,6 @@ func TestHandleDispatchConflictError(t *testing.T) {
154
153
155
154
func TestBatchSizeOverflow (t * testing.T ) {
156
155
log .SetLevel ("debug" )
157
- coreconfig .Reset ()
158
156
159
157
dispatched := make (chan * DispatchPayload )
160
158
cancel , mdi , bp := newTestBatchProcessor (t , func (c context.Context , state * DispatchPayload ) error {
@@ -553,7 +551,6 @@ func TestStartQuiesceNonBlocking(t *testing.T) {
553
551
554
552
func TestMarkMessageDispatchedUnpinnedOK (t * testing.T ) {
555
553
log .SetLevel ("debug" )
556
- coreconfig .Reset ()
557
554
558
555
dispatched := make (chan * DispatchPayload )
559
556
cancel , mdi , bp := newTestBatchProcessor (t , func (c context.Context , state * DispatchPayload ) error {
@@ -611,7 +608,6 @@ func TestMarkMessageDispatchedUnpinnedOK(t *testing.T) {
611
608
612
609
func TestMaskContextsRetryAfterPinsAssigned (t * testing.T ) {
613
610
log .SetLevel ("debug" )
614
- coreconfig .Reset ()
615
611
616
612
dispatched := make (chan * DispatchPayload )
617
613
cancel , mdi , bp := newTestBatchProcessor (t , func (c context.Context , state * DispatchPayload ) error {
@@ -681,7 +677,6 @@ func TestMaskContextsRetryAfterPinsAssigned(t *testing.T) {
681
677
682
678
func TestMaskContextsUpdateMessageFail (t * testing.T ) {
683
679
log .SetLevel ("debug" )
684
- coreconfig .Reset ()
685
680
686
681
dispatched := make (chan * DispatchPayload )
687
682
cancel , mdi , bp := newTestBatchProcessor (t , func (c context.Context , state * DispatchPayload ) error {
@@ -720,7 +715,6 @@ func TestMaskContextsUpdateMessageFail(t *testing.T) {
720
715
}
721
716
722
717
func TestSealBatchTXAlreadyAssigned (t * testing.T ) {
723
- coreconfig .Reset ()
724
718
725
719
dispatched := make (chan * DispatchPayload )
726
720
cancel , mdi , bp := newTestBatchProcessor (t , func (c context.Context , state * DispatchPayload ) error {
@@ -831,7 +825,6 @@ func TestCalculateContextsLoadPinsFail(t *testing.T) {
831
825
832
826
func TestBigBatchEstimate (t * testing.T ) {
833
827
log .SetLevel ("debug" )
834
- coreconfig .Reset ()
835
828
836
829
bd := []byte (`{
837
830
"id": "37ba893b-fcfa-4cf9-8ce8-34cd8bc9bc72",
0 commit comments