Remove addProcessingItems

Co-authored-by: Fredrik Adelöw <freben@users.noreply.github.com>
Co-authored-by: Ben Lambert <ben@blam.sh>
Co-authored-by: Patrik Oldsberg <poldsberg@gmail.com>
Signed-off-by: Johan Haals <johan.haals@gmail.com>
This commit is contained in:
Johan Haals
2021-04-26 14:02:41 +02:00
committed by blam
parent fd7cd5d449
commit 19b07a6f67
2 changed files with 2 additions and 9 deletions
+2 -2
View File
@@ -19,7 +19,7 @@ import { Logger } from 'winston';
import { Transaction } from '../database';
import { ConflictError } from '@backstage/errors';
import {
DbRefreshStateReferences,
DbRefreshStateReferencesRow,
DbRefreshStateRow,
DbRelationsRow,
} from './database/DefaultProcessingDatabase';
@@ -73,7 +73,7 @@ export class Stitcher {
return;
}
const [reference_count_result] = await tx<DbRefreshStateReferences>(
const [reference_count_result] = await tx<DbRefreshStateReferencesRow>(
'refresh_state_references',
)
.where({ target_entity_ref: entityRef })
@@ -101,12 +101,6 @@ export type ProcessingItemResult = {
deferredEntities: Entity[];
};
export type AddProcessingItemRequest = {
type: 'entity' | 'provider';
id: string;
entities: Entity[];
};
export type ProcessingItem = {
id: string;
entity: Entity;
@@ -128,6 +122,5 @@ export type ReplaceProcessingItemsRequest =
export interface ProcessingStateManager {
setProcessingItemResult(result: ProcessingItemResult): Promise<void>;
getNextProcessingItem(): Promise<ProcessingItem>;
addProcessingItems(request: AddProcessingItemRequest): Promise<void>;
replaceProcessingItems(request: ReplaceProcessingItemsRequest): Promise<void>;
}