diff --git a/packages/indexer-common/src/actions.ts b/packages/indexer-common/src/actions.ts index a6f920ab8..9aec66814 100644 --- a/packages/indexer-common/src/actions.ts +++ b/packages/indexer-common/src/actions.ts @@ -1,5 +1,6 @@ import { NetworkMonitor } from './indexer-management' import { AllocationStatus } from './allocations' +import { Logger } from '@graphprotocol/common-ts' import { WhereOperators, WhereOptions } from 'sequelize' import { Op } from 'sequelize' import { WhereAttributeHashValue } from 'sequelize/types/model' @@ -81,6 +82,7 @@ export const isValidActionInput = ( export const validateActionInputs = async ( actions: ActionInput[], networkMonitor: NetworkMonitor, + logger: Logger, ): Promise => { // Validate actions before adding to queue // TODO: Perform all checks simultaneously and throw combined error if 1 or more fail @@ -125,7 +127,7 @@ export const validateActionInputs = async ( action.deploymentID, ) if (!subgraphDeployment) { - throw new Error( + logger.warn( `No subgraphDeployment with ipfsHash = '${action.deploymentID}' found on the network`, ) } diff --git a/packages/indexer-common/src/indexer-management/resolvers/actions.ts b/packages/indexer-common/src/indexer-management/resolvers/actions.ts index 7baa422bc..d82b70800 100644 --- a/packages/indexer-common/src/indexer-management/resolvers/actions.ts +++ b/packages/indexer-common/src/indexer-management/resolvers/actions.ts @@ -173,7 +173,7 @@ export default { await multiNetworks.mapNetworkMapped( groupBy(actions, (action) => action.protocolNetwork), (network: Network, actions: ActionInput[]) => - validateActionInputs(actions, network.networkMonitor), + validateActionInputs(actions, network.networkMonitor, logger), ) const alreadyQueuedActions = await ActionManager.fetchActions(models, {