chore: fix job-worker linter/type errors

Julusian · Julusian · commit 6d0ff435b854 · 2025-01-29T11:51:05.000Z
diff --git a/packages/job-worker/src/__mocks__/_setupMocks.ts b/packages/job-worker/src/__mocks__/_setupMocks.ts
@@ -1,4 +1,4 @@
-/* eslint-disable @typescript-eslint/no-var-requires */
+/* eslint-disable @typescript-eslint/no-require-imports */
 
 import './_extendJest.js'
 
diff --git a/packages/job-worker/src/blueprints/__tests__/context-OnSetAsNextContext.test.ts b/packages/job-worker/src/blueprints/__tests__/context-OnSetAsNextContext.test.ts
@@ -1,4 +1,4 @@
-/* eslint-disable @typescript-eslint/no-non-null-assertion, @typescript-eslint/unbound-method */
+/* eslint-disable @typescript-eslint/unbound-method */
 import { IBlueprintMutatablePart, IBlueprintPiece } from '@sofie-automation/blueprints-integration'
 import { PlayoutModel } from '../../playout/model/PlayoutModel.js'
 import { WatchedPackagesHelper } from '../context/watchedPackages.js'
diff --git a/packages/job-worker/src/blueprints/__tests__/context-OnTakeContext.test.ts b/packages/job-worker/src/blueprints/__tests__/context-OnTakeContext.test.ts
@@ -1,4 +1,4 @@
-/* eslint-disable @typescript-eslint/no-non-null-assertion, @typescript-eslint/unbound-method */
+/* eslint-disable @typescript-eslint/unbound-method */
 import { IBlueprintMutatablePart, IBlueprintPiece } from '@sofie-automation/blueprints-integration'
 import { PlayoutModel } from '../../playout/model/PlayoutModel.js'
 import { WatchedPackagesHelper } from '../context/watchedPackages.js'
diff --git a/packages/job-worker/src/blueprints/__tests__/context-adlibActions.test.ts b/packages/job-worker/src/blueprints/__tests__/context-adlibActions.test.ts
@@ -1,4 +1,4 @@
-/* eslint-disable @typescript-eslint/no-non-null-assertion, @typescript-eslint/unbound-method */
+/* eslint-disable @typescript-eslint/unbound-method */
 import { IBlueprintMutatablePart, IBlueprintPart, IBlueprintPiece } from '@sofie-automation/blueprints-integration'
 import { ActionExecutionContext } from '../context/adlibActions.js'
 import { PlayoutModel } from '../../playout/model/PlayoutModel.js'
diff --git a/packages/job-worker/src/blueprints/__tests__/postProcess.test.ts b/packages/job-worker/src/blueprints/__tests__/postProcess.test.ts
@@ -111,7 +111,7 @@ describe('Test blueprint post-process', () => {
 
 			// Certain fields should be defined by simple rules
 			expect(res.filter((r) => r.id === '')).toHaveLength(0)
-			expect(res.filter((r) => r.objectType !== 'rundown')).toHaveLength(0)
+			expect(res.filter((r) => r.objectType !== TimelineObjType.RUNDOWN)).toHaveLength(0)
 
 			// Ensure no ids were duplicates
 			const ids = res.map((obj) => obj.id)
@@ -229,7 +229,7 @@ describe('Test blueprint post-process', () => {
 
 			// Certain fields should be defined by simple rules
 			expect(res.filter((r) => r.id === '')).toHaveLength(0)
-			expect(res.filter((r) => r.objectType !== 'rundown')).toHaveLength(0)
+			expect(res.filter((r) => r.objectType !== TimelineObjType.RUNDOWN)).toHaveLength(0)
 
 			// Ensure getHash was called as expected
 			expect(getHashMock).toHaveBeenCalledTimes(2)
diff --git a/packages/job-worker/src/blueprints/config.ts b/packages/job-worker/src/blueprints/config.ts
@@ -34,6 +34,7 @@ export async function retrieveBlueprintConfigRefs(
 	const refs = stringWithReferences.match(/\$\{[^}]+\}/g) || []
 	for (const ref of refs) {
 		if (ref) {
+			// eslint-disable-next-line @typescript-eslint/no-base-to-string
 			let value = (await retrieveBlueprintConfigRef(context, ref, bailOnError)) + ''
 			if (value) {
 				if (modifier) value = modifier(value)
diff --git a/packages/job-worker/src/blueprints/context/OnTakeContext.ts b/packages/job-worker/src/blueprints/context/OnTakeContext.ts
@@ -111,10 +111,10 @@ export class OnTakeContext extends ShowStyleUserContext implements IOnTakeContex
 		return this.partAndPieceInstanceService.updatePartInstance(part, props)
 	}
 
-	async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number | undefined): Promise<string[]> {
+	async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number): Promise<string[]> {
 		return this.partAndPieceInstanceService.stopPiecesOnLayers(sourceLayerIds, timeOffset)
 	}
-	async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number | undefined): Promise<string[]> {
+	async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number): Promise<string[]> {
 		return this.partAndPieceInstanceService.stopPieceInstances(pieceInstanceIds, timeOffset)
 	}
 	async removePieceInstances(part: 'next', pieceInstanceIds: string[]): Promise<string[]> {
diff --git a/packages/job-worker/src/blueprints/context/adlibActions.ts b/packages/job-worker/src/blueprints/context/adlibActions.ts
@@ -175,11 +175,11 @@ export class ActionExecutionContext extends ShowStyleUserContext implements IAct
 		return this.partAndPieceInstanceService.updatePartInstance(part, props)
 	}
 
-	async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number | undefined): Promise<string[]> {
+	async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number): Promise<string[]> {
 		return this.partAndPieceInstanceService.stopPiecesOnLayers(sourceLayerIds, timeOffset)
 	}
 
-	async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number | undefined): Promise<string[]> {
+	async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number): Promise<string[]> {
 		return this.partAndPieceInstanceService.stopPieceInstances(pieceInstanceIds, timeOffset)
 	}
 
diff --git a/packages/job-worker/src/blueprints/context/services/__tests__/PartAndPieceInstanceActionService.test.ts b/packages/job-worker/src/blueprints/context/services/__tests__/PartAndPieceInstanceActionService.test.ts
@@ -1603,7 +1603,6 @@ describe('Test blueprint api context', () => {
 
 					await expect(service.removePieceInstances('next', [])).resolves.toEqual([])
 					await expect(
-						// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
 						service.removePieceInstances('next', [unprotectString(pieceInstanceFromOther._id)])
 					).resolves.toEqual([]) // Try and remove something belonging to a different part
 					expectCountsToEqual(getPieceInstanceCounts(playoutModel), beforePieceInstancesCounts)
diff --git a/packages/job-worker/src/blueprints/ingest/MutableIngestPartImpl.ts b/packages/job-worker/src/blueprints/ingest/MutableIngestPartImpl.ts
@@ -51,7 +51,6 @@ export class MutableIngestPartImpl<TPartPayload = unknown> implements MutableIng
 		}
 
 		if (this.#hasChanges || !_.isEqual(this.#ingestPart.payload[key], value)) {
-			// eslint-disable-next-line @typescript-eslint/no-unnecessary-type-assertion
 			;(this.#ingestPart.payload as any)[key] = clone(value)
 			this.#hasChanges = true
 		}
diff --git a/packages/job-worker/src/blueprints/ingest/MutableIngestRundownImpl.ts b/packages/job-worker/src/blueprints/ingest/MutableIngestRundownImpl.ts
@@ -117,7 +117,6 @@ export class MutableIngestRundownImpl<TRundownPayload = unknown, TSegmentPayload
 		}
 
 		if (this.#hasChangesToRundown || !_.isEqual(this.ingestRundown.payload[key], value)) {
-			// eslint-disable-next-line @typescript-eslint/no-unnecessary-type-assertion
 			;(this.ingestRundown.payload as any)[key] = clone(value)
 			this.#hasChangesToRundown = true
 		}
diff --git a/packages/job-worker/src/blueprints/ingest/MutableIngestSegmentImpl.ts b/packages/job-worker/src/blueprints/ingest/MutableIngestSegmentImpl.ts
@@ -200,7 +200,6 @@ export class MutableIngestSegmentImpl<TSegmentPayload = unknown, TPartPayload =
 		}
 
 		if (this.#segmentHasChanges || !_.isEqual(this.#ingestSegment.payload[key], value)) {
-			// eslint-disable-next-line @typescript-eslint/no-unnecessary-type-assertion
 			;(this.#ingestSegment.payload as any)[key] = clone(value)
 			this.#segmentHasChanges = true
 		}
diff --git a/packages/job-worker/src/blueprints/ingest/defaultApplyIngestChanges.ts b/packages/job-worker/src/blueprints/ingest/defaultApplyIngestChanges.ts
@@ -12,6 +12,7 @@ import {
 	NrcsIngestPartChangeDetails,
 	IngestPart,
 	MutableIngestPart,
+	IngestChangeType,
 } from '@sofie-automation/blueprints-integration'
 import { assertNever, normalizeArrayToMap } from '@sofie-automation/corelib/dist/lib'
 import { ReadonlyDeep } from 'type-fest'
@@ -29,7 +30,7 @@ export function defaultApplyIngestChanges<TRundownPayload, TSegmentPayload, TPar
 	ingestChanges: NrcsIngestChangeDetails,
 	options: IngestDefaultChangesOptions<TRundownPayload, TSegmentPayload, TPartPayload>
 ): void {
-	if (ingestChanges.source !== 'ingest')
+	if (ingestChanges.source !== IngestChangeType.Ingest)
 		throw new Error(`Changes passed to defaultApplyIngestChanges must be from ingest source`)
 
 	const payloadTransformers = new PayloadTransformers(options, mutableIngestRundown)
diff --git a/packages/job-worker/src/blueprints/postProcess.ts b/packages/job-worker/src/blueprints/postProcess.ts
@@ -334,7 +334,7 @@ export function postProcessAdLibActions(
 	return adlibActions.map((action) => {
 		if (!action.externalId)
 			throw new Error(
-				`Error in blueprint "${blueprintId}" externalId not set for adlib action in ${partId}! ("${action.display.label}")`
+				`Error in blueprint "${blueprintId}" externalId not set for adlib action in ${partId}! ("${typeof action.display.label === 'string' ? action.display.label : action.display.label.key}")`
 			)
 
 		const docId = getIdHash(
diff --git a/packages/job-worker/src/events/ExternalMessageQueue.ts b/packages/job-worker/src/events/ExternalMessageQueue.ts
@@ -13,7 +13,7 @@ import { sendSlackMessageToWebhook } from './integration/slack.js'
 import { StudioCacheContext } from '../jobs/index.js'
 import { InvalidateWorkerDataCache, WorkerDataCacheWrapper } from '../workers/caches.js'
 import { ReadonlyDeep } from 'type-fest'
-import pTimeout = require('p-timeout')
+import pTimeout from 'p-timeout'
 import { logger } from '../logging.js'
 
 const TRIGGER_DELAY_DEFAULT = 1000 // TODO: Now that this is in its own thread, does it need a delay?
diff --git a/packages/job-worker/src/ingest/__tests__/ingest.test.ts b/packages/job-worker/src/ingest/__tests__/ingest.test.ts
@@ -1,4 +1,3 @@
-/* eslint-disable @typescript-eslint/unbound-method */
 import '../../__mocks__/_extendJest.js'
 import {
 	IBlueprintPiece,
diff --git a/packages/job-worker/src/ingest/__tests__/ingestPartJobs.spec.ts b/packages/job-worker/src/ingest/__tests__/ingestPartJobs.spec.ts
@@ -288,27 +288,4 @@ describe('handleUpdatedPart', () => {
 			},
 		} satisfies UpdateIngestRundownChange)
 	})
-
-	// TODO: should this be a test case?
-	// it('part belongs to different segment', () => {
-	// 	const context = setupDefaultJobEnvironment()
-
-	// 	const ingestRundown = getDefaultIngestRundown()
-
-	// 	const newIngestPart2 = { ...newIngestPart, externalId: 'part0' }
-
-	// 	expect(() =>
-	// 		handleUpdatedPart(
-	// 			context,
-	// 			{
-	// 				peripheralDeviceId: null,
-	// 				rundownExternalId: 'rundown0',
-	// 				segmentExternalId: 'segment1',
-	// 				ingestPart: clone(newIngestPart2),
-	// 				isCreateAction: true,
-	// 			},
-	// 			clone(ingestRundown)
-	// 		)
-	// 	).toThrow('TODO fill out this error')
-	// })
 })
diff --git a/packages/job-worker/src/ingest/runOperation.ts b/packages/job-worker/src/ingest/runOperation.ts
@@ -14,6 +14,7 @@ import {
 	IngestRundown,
 	UserOperationChange,
 	SofieIngestSegment,
+	IngestChangeType,
 } from '@sofie-automation/blueprints-integration'
 import { MutableIngestRundownImpl } from '../blueprints/ingest/MutableIngestRundownImpl.js'
 import { ProcessIngestDataContext } from '../blueprints/context/index.js'
@@ -299,7 +300,7 @@ async function updateSofieIngestRundown(
 				previousNrcsIngestRundown,
 				ingestRundownChanges.changes
 			)
-		} else if (ingestRundownChanges.changes.source === 'ingest') {
+		} else if (ingestRundownChanges.changes.source === IngestChangeType.Ingest) {
 			// Backwards compatible mode: Blueprints has not defined a processIngestData()
 			// so we'll simply accept the incoming changes as-is:
 
diff --git a/packages/job-worker/src/lib/lazy.ts b/packages/job-worker/src/lib/lazy.ts
@@ -1,4 +1,4 @@
-import PLazy = require('p-lazy')
+import PLazy from 'p-lazy'
 
 export interface LazyInitialiseReadonly<T> {
 	/** Return the value, loading it if required */
diff --git a/packages/job-worker/src/main.ts b/packages/job-worker/src/main.ts
@@ -75,7 +75,7 @@ export abstract class JobWorkerBase {
 			logger.debug('Mongo connection closed. Forcing exit')
 			// Note: This is terribele error handling, but it does the job.
 			// If we start handling this more gracefully, then we will need to make sure to avoid/kill jobs being processed and flush all caches upon reconnection
-			// eslint-disable-next-line no-process-exit
+			// eslint-disable-next-line n/no-process-exit
 			process.exit(0)
 		})
 
@@ -150,14 +150,14 @@ async function getStudioIdsToRun(db: MongoDb): Promise<Array<StudioId>> {
 					// Something about the list of studios that exist has changed, lets restart
 					// The easiest thing to do is to restart the process. This will happen so rarely, its probably not worth trying to improve on
 
-					// eslint-disable-next-line no-process-exit
+					// eslint-disable-next-line n/no-process-exit
 					process.exit(1)
 				}
 			})
 			.on('end', () => {
 				logger.warn(`Changes stream for Studios ended`)
 				// Note: This is terribele error handling, but it does the job.
-				// eslint-disable-next-line no-process-exit
+				// eslint-disable-next-line n/no-process-exit
 				process.exit(1)
 			})
 
diff --git a/packages/job-worker/src/playout/lookahead/__tests__/lookahead.test.ts b/packages/job-worker/src/playout/lookahead/__tests__/lookahead.test.ts
@@ -341,6 +341,7 @@ describe('Lookahead', () => {
 		await expectLookaheadForLayerMock(playlistId, [expectedCurrent, expectedNext], expectedPrevious, fakeParts)
 	})
 
+	// eslint-disable-next-line jest/no-commented-out-tests
 	// test('Pieces', () => {
 	// 	const fakeParts = partIds.map((p) => ({ _id: p })) as Part[]
 	// 	getOrderedPartsAfterPlayheadMock.mockReturnValue(fakeParts)
diff --git a/packages/job-worker/src/playout/setNext.ts b/packages/job-worker/src/playout/setNext.ts
@@ -45,7 +45,7 @@ export async function setNextPart(
 	playoutModel: PlayoutModel,
 	rawNextPart: ReadonlyDeep<Omit<SelectNextPartResult, 'index'>> | PlayoutPartInstanceModel | null,
 	setManually: boolean,
-	nextTimeOffset?: number | undefined
+	nextTimeOffset?: number
 ): Promise<void> {
 	const span = context.startSpan('setNextPart')
 
@@ -102,7 +102,7 @@ async function setNextPartAndCheckForPendingMoveNextPart(
 	playoutModel: PlayoutModel,
 	rawNextPart: ReadonlyDeep<Omit<SelectNextPartResult, 'index'>> | PlayoutPartInstanceModel | null,
 	setManually: boolean,
-	nextTimeOffset?: number | undefined
+	nextTimeOffset?: number
 ): Promise<{ selectedPart: ReadonlyDeep<DBPart> | null } | undefined> {
 	if (rawNextPart) {
 		if (!playoutModel.playlist.activationId)
@@ -551,7 +551,7 @@ export async function setNextPartFromPart(
 	playoutModel: PlayoutModel,
 	nextPart: ReadonlyDeep<DBPart>,
 	setManually: boolean,
-	nextTimeOffset?: number | undefined
+	nextTimeOffset?: number
 ): Promise<void> {
 	const playlist = playoutModel.playlist
 	if (!playlist.activationId) throw UserError.create(UserErrorMessage.InactiveRundown)
diff --git a/packages/job-worker/src/playout/timeline/part.ts b/packages/job-worker/src/playout/timeline/part.ts
@@ -53,10 +53,7 @@ export function transformPartIntoTimeline(
 			case IBlueprintPieceType.OutTransition:
 				if (outTransition) {
 					pieceEnable = {
-						start: `#${parentGroup.id}.end - ${outTransition.duration}`,
-					}
-					if (partTimings.toPartPostroll) {
-						pieceEnable.start += ' - ' + partTimings.toPartPostroll
+						start: `#${parentGroup.id}.end - ${outTransition.duration + partTimings.toPartPostroll}`,
 					}
 				}
 				break
diff --git a/packages/job-worker/src/playout/timeline/rundown.ts b/packages/job-worker/src/playout/timeline/rundown.ts
@@ -85,16 +85,18 @@ export function buildTimelineObjsForRundown(
 	// Fetch the nextPart first, because that affects how the currentPart will be treated
 	if (activePlaylist.nextPartInfo) {
 		// We may be at the end of a show, where there is no next part
-		if (!partInstancesInfo.next) throw new Error(`PartInstance "${activePlaylist.nextPartInfo}" not found!`)
+		if (!partInstancesInfo.next)
+			throw new Error(`PartInstance "${activePlaylist.nextPartInfo?.partInstanceId}" not found!`)
 	}
 	if (activePlaylist.currentPartInfo) {
 		// We may be before the beginning of a show, and there can be no currentPart and we are waiting for the user to Take
-		if (!partInstancesInfo.current) throw new Error(`PartInstance "${activePlaylist.currentPartInfo}" not found!`)
+		if (!partInstancesInfo.current)
+			throw new Error(`PartInstance "${activePlaylist.currentPartInfo?.partInstanceId}" not found!`)
 	}
 	if (activePlaylist.previousPartInfo) {
 		// We may be at the beginning of a show, where there is no previous part
 		if (!partInstancesInfo.previous)
-			logger.warn(`Previous PartInstance "${activePlaylist.previousPartInfo}" not found!`)
+			logger.warn(`Previous PartInstance "${activePlaylist.previousPartInfo?.partInstanceId}" not found!`)
 	}
 
 	if (!partInstancesInfo.next && !partInstancesInfo.current) {
diff --git a/packages/job-worker/src/showStyles.ts b/packages/job-worker/src/showStyles.ts
@@ -1,6 +1,6 @@
 import { IBlueprintConfig } from '@sofie-automation/blueprints-integration'
 import { deepFreeze } from '@sofie-automation/corelib/dist/lib'
-import * as deepmerge from 'deepmerge'
+import deepmerge from 'deepmerge'
 import { ReadonlyDeep } from 'type-fest'
 import { ProcessedShowStyleBase, ProcessedShowStyleVariant, ProcessedShowStyleCompound } from './jobs/index.js'
 
diff --git a/packages/job-worker/src/workers/caches.ts b/packages/job-worker/src/workers/caches.ts
@@ -14,7 +14,7 @@ import { DefaultStudioBlueprint } from '../blueprints/defaults/studio.js'
 import { protectString } from '@sofie-automation/corelib/dist/protectedString'
 import { clone, deepFreeze } from '@sofie-automation/corelib/dist/lib'
 import { logger } from '../logging.js'
-import deepmerge = require('deepmerge')
+import deepmerge from 'deepmerge'
 import { JobStudio, ProcessedShowStyleBase, ProcessedShowStyleVariant, StudioCacheContext } from '../jobs/index.js'
 import { StudioCacheContextImpl } from './context/StudioCacheContextImpl.js'
 import { convertStudioToJobStudio } from '../jobs/studio.js'
diff --git a/packages/job-worker/tsconfig.build.json b/packages/job-worker/tsconfig.build.json
@@ -11,6 +11,7 @@
 		},
 		"resolveJsonModule": true,
 		"types": ["node"],
-		"skipLibCheck": true
+		"skipLibCheck": true,
+		"esModuleInterop": true
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-/* eslint-disable @typescript-eslint/no-var-requires */`
	`1`	`+/* eslint-disable @typescript-eslint/no-require-imports */`
`2`	`2`
`3`	`3`	`import './_extendJest.js'`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-/* eslint-disable @typescript-eslint/no-non-null-assertion, @typescript-eslint/unbound-method */`
	`1`	`+/* eslint-disable @typescript-eslint/unbound-method */`
`2`	`2`	`import { IBlueprintMutatablePart, IBlueprintPiece } from '@sofie-automation/blueprints-integration'`
`3`	`3`	`import { PlayoutModel } from '../../playout/model/PlayoutModel.js'`
`4`	`4`	`import { WatchedPackagesHelper } from '../context/watchedPackages.js'`
Original file line number	Diff line number	Diff line change
`@@ -111,10 +111,10 @@ export class OnTakeContext extends ShowStyleUserContext implements IOnTakeContex`
`111`	`111`	`return this.partAndPieceInstanceService.updatePartInstance(part, props)`
`112`	`112`	`}`
`113`	`113`
`114`		`- async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number \| undefined): Promise<string[]> {`
	`114`	`+ async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number): Promise<string[]> {`
`115`	`115`	`return this.partAndPieceInstanceService.stopPiecesOnLayers(sourceLayerIds, timeOffset)`
`116`	`116`	`}`
`117`		`- async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number \| undefined): Promise<string[]> {`
	`117`	`+ async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number): Promise<string[]> {`
`118`	`118`	`return this.partAndPieceInstanceService.stopPieceInstances(pieceInstanceIds, timeOffset)`
`119`	`119`	`}`
`120`	`120`	`async removePieceInstances(part: 'next', pieceInstanceIds: string[]): Promise<string[]> {`
Original file line number	Diff line number	Diff line change
`@@ -175,11 +175,11 @@ export class ActionExecutionContext extends ShowStyleUserContext implements IAct`
`175`	`175`	`return this.partAndPieceInstanceService.updatePartInstance(part, props)`
`176`	`176`	`}`
`177`	`177`
`178`		`- async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number \| undefined): Promise<string[]> {`
	`178`	`+ async stopPiecesOnLayers(sourceLayerIds: string[], timeOffset?: number): Promise<string[]> {`
`179`	`179`	`return this.partAndPieceInstanceService.stopPiecesOnLayers(sourceLayerIds, timeOffset)`
`180`	`180`	`}`
`181`	`181`
`182`		`- async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number \| undefined): Promise<string[]> {`
	`182`	`+ async stopPieceInstances(pieceInstanceIds: string[], timeOffset?: number): Promise<string[]> {`
`183`	`183`	`return this.partAndPieceInstanceService.stopPieceInstances(pieceInstanceIds, timeOffset)`
`184`	`184`	`}`
`185`	`185`
Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,6 @@ export class MutableIngestPartImpl<TPartPayload = unknown> implements MutableIng`
`51`	`51`	`}`
`52`	`52`
`53`	`53`	`if (this.#hasChanges \|\| !_.isEqual(this.#ingestPart.payload[key], value)) {`
`54`		`- // eslint-disable-next-line @typescript-eslint/no-unnecessary-type-assertion`
`55`	`54`	`;(this.#ingestPart.payload as any)[key] = clone(value)`
`56`	`55`	`this.#hasChanges = true`
`57`	`56`	`}`