Skip to content

Commit 001568b

Browse files
committed
style: Lint
1 parent b3241e0 commit 001568b

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

scheduler/scheduler_test.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -192,17 +192,17 @@ const chunkSize = 200
192192
func testTableSuccessWithRowsChunkResolverSendSingleItemToResChan() *schema.Table {
193193
return &schema.Table{
194194
Name: "test_table_success_with_rows_chunk_resolver",
195-
Resolver: func(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- any) error {
195+
Resolver: func(_ context.Context, _ schema.ClientMeta, _ *schema.Resource, res chan<- any) error {
196196
for i := range chunkSize {
197197
res <- i
198198
}
199199
return nil
200200
},
201201
PreResourceChunkResolver: &schema.RowsChunkResolver{
202202
ChunkSize: chunkSize,
203-
RowsResolver: func(ctx context.Context, meta schema.ClientMeta, resourcesChunk []*schema.Resource) error {
203+
RowsResolver: func(_ context.Context, _ schema.ClientMeta, resourcesChunk []*schema.Resource) error {
204204
for _, resource := range resourcesChunk {
205-
resource.Set("test_column", strconv.Itoa(resource.Item.(int)))
205+
_ = resource.Set("test_column", strconv.Itoa(resource.Item.(int)))
206206
}
207207
return nil
208208
},
@@ -219,7 +219,7 @@ func testTableSuccessWithRowsChunkResolverSendSingleItemToResChan() *schema.Tabl
219219
func testTableSuccessWithRowsChunkResolverSendSliceToResChan() *schema.Table {
220220
return &schema.Table{
221221
Name: "test_table_success_with_rows_chunk_resolver",
222-
Resolver: func(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- any) error {
222+
Resolver: func(_ context.Context, _ schema.ClientMeta, _ *schema.Resource, res chan<- any) error {
223223
data := make([]int, chunkSize)
224224
for i := range chunkSize {
225225
data[i] = i
@@ -229,9 +229,9 @@ func testTableSuccessWithRowsChunkResolverSendSliceToResChan() *schema.Table {
229229
},
230230
PreResourceChunkResolver: &schema.RowsChunkResolver{
231231
ChunkSize: chunkSize,
232-
RowsResolver: func(ctx context.Context, meta schema.ClientMeta, resourcesChunk []*schema.Resource) error {
232+
RowsResolver: func(_ context.Context, _ schema.ClientMeta, resourcesChunk []*schema.Resource) error {
233233
for _, resource := range resourcesChunk {
234-
resource.Set("test_column", strconv.Itoa(resource.Item.(int)))
234+
_ = resource.Set("test_column", strconv.Itoa(resource.Item.(int)))
235235
}
236236
return nil
237237
},
@@ -245,11 +245,11 @@ func testTableSuccessWithRowsChunkResolverSendSliceToResChan() *schema.Table {
245245
}
246246
}
247247

248-
func expectedChunkedResolverData(schema *arrow.Schema) []arrow.Record {
248+
func expectedChunkedResolverData(s *arrow.Schema) []arrow.Record {
249249
const rowsPerRecord = 50
250250
data := make([]arrow.Record, chunkSize/rowsPerRecord)
251251
for i := range data {
252-
builder := array.NewRecordBuilder(memory.DefaultAllocator, schema)
252+
builder := array.NewRecordBuilder(memory.DefaultAllocator, s)
253253
for j := range rowsPerRecord {
254254
builder.Field(0).(*array.StringBuilder).Append(strconv.Itoa(i*rowsPerRecord + j))
255255
}

0 commit comments

Comments
 (0)