Skip to content

Commit 6d3c62b

Browse files
committed
fix: lint
Signed-off-by: Umberto Sgueglia <usgueglia@contractor.linuxfoundation.org>
1 parent b7c4084 commit 6d3c62b

2 files changed

Lines changed: 18 additions & 4 deletions

File tree

  • services/apps/automatic_projects_discovery_worker/src

services/apps/automatic_projects_discovery_worker/src/activities/activities.ts

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
import { parse } from 'csv-parse'
22

3-
import { bulkUpsertProjectCatalog, findLatestProjectCatalogSyncedAt } from '@crowd/data-access-layer'
3+
import {
4+
bulkUpsertProjectCatalog,
5+
findLatestProjectCatalogSyncedAt,
6+
} from '@crowd/data-access-layer'
47
import { IDbProjectCatalogCreate } from '@crowd/data-access-layer/src/project-catalog/types'
58
import { pgpQx } from '@crowd/data-access-layer/src/queryExecutor'
69
import { getServiceLogger } from '@crowd/logging'
@@ -112,7 +115,10 @@ export async function processDataset(
112115
// Flush remaining rows that didn't fill a complete batch
113116
if (batch.length > 0) {
114117
batchNumber++
115-
log.info({ sourceName, datasetId: dataset.id, batchSize: batch.length }, 'Flushing final batch...')
118+
log.info(
119+
{ sourceName, datasetId: dataset.id, batchSize: batch.length },
120+
'Flushing final batch...',
121+
)
116122
await bulkUpsertProjectCatalog(qx, batch)
117123
totalProcessed += batch.length
118124
}

services/apps/automatic_projects_discovery_worker/src/sources/lf-criticality-score/source.ts

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,13 +116,21 @@ export class LfCriticalityScoreSource implements IDiscoverySource {
116116
let totalPages = 1
117117

118118
do {
119-
log.info({ datasetId: dataset.id, page, totalPages }, 'LF Criticality Score: fetching page...')
119+
log.info(
120+
{ datasetId: dataset.id, page, totalPages },
121+
'LF Criticality Score: fetching page...',
122+
)
120123
const response = await fetchPage(baseUrl, page, scoredAfter)
121124
totalPages = response.totalPages
122125

123126
if (page === 1) {
124127
log.info(
125-
{ datasetId: dataset.id, total: response.total, totalPages, pageSize: response.pageSize },
128+
{
129+
datasetId: dataset.id,
130+
total: response.total,
131+
totalPages,
132+
pageSize: response.pageSize,
133+
},
126134
'LF Criticality Score: first page received — total records available.',
127135
)
128136
}

0 commit comments

Comments
 (0)