@@ -14,9 +14,8 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
import { ProcessingDatabase, RefreshStateItem } from './database/types';
|
||||
import { ProcessingDatabase } from './database/types';
|
||||
import {
|
||||
AddProcessingItemRequest,
|
||||
ProcessingItem,
|
||||
ProcessingItemResult,
|
||||
ProcessingStateManager,
|
||||
@@ -47,12 +46,6 @@ export class DefaultProcessingStateManager implements ProcessingStateManager {
|
||||
});
|
||||
}
|
||||
|
||||
async addProcessingItems(request: AddProcessingItemRequest) {
|
||||
return this.db.transaction(async tx => {
|
||||
// await this.db.addUnprocessedEntities(tx, request);
|
||||
});
|
||||
}
|
||||
|
||||
async getNextProcessingItem(): Promise<ProcessingItem> {
|
||||
for (;;) {
|
||||
const { items } = await this.db.transaction(async tx => {
|
||||
|
||||
Reference in New Issue
Block a user