Method run

src/storage/dgraph/index.ts:184–202

* Executes mutations sequentially into Dgraph

(dropData = true)

   * Executes mutations sequentially into Dgraph
   */
  async run(dropData = true): Promise<void> {
    dropData && (await this.dropData())
    for (const mutation of this.axiosPromises) {
      try {
        await mutation()
      } catch (error: any) {
        const {
          response: { data: resData, errors } = { data: null, errors: null },
          message,
        } = error ?? {}
        this.logger.error('There was an issue pushing data into the Dgraph db')
        this.logger.debug(message)
        processGQLExecutionResult({ resData, errors })
      }
    }

    // Ensure mutations array is clean after execution
    this.axiosPromises = []
  }
}