Skip to content

Commit 7a1cdc7

Browse files
committed
fix linting issues
1 parent 670d667 commit 7a1cdc7

2 files changed

Lines changed: 2 additions & 4 deletions

File tree

internal/persistence/filequeue/job.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,5 +96,5 @@ func (j *Job) ID() string {
9696
}
9797

9898
func (j *Job) Data() (*execution.DAGRunRef, error) {
99-
return &j.ItemData.DAGRun, nil
99+
return &j.DAGRun, nil
100100
}

internal/persistence/filequeue/queue.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -96,9 +96,7 @@ func (q *DualQueue) DequeueByDAGRunID(ctx context.Context, dagRun execution.DAGR
9696
logger.Error(ctx, "Failed to pop dag-run from queue file", tag.Error(err))
9797
return nil, fmt.Errorf("failed to pop dag-run %s: %w", dagRun.ID, err)
9898
}
99-
for _, item := range popped {
100-
items = append(items, item)
101-
}
99+
items = append(items, popped...)
102100
}
103101

104102
// Remove directory if it's empty

0 commit comments

Comments
 (0)