Method drainRelsToStore

ui/src/job/browserJobService.ts:512–528

()

      /** Drain buffered relationships from the store stage and persist them. */
      const drainRelsToStore = async () => {
        const rels = storeStage!.drainRelationships();
        if (rels.length === 0) return;
        debug.log('store', `draining ${rels.length} rels`);
        await this.store.importBatch({
          nodes: [],
          relationships: rels.map((r) => ({
            id: r.id,
            type: r.type,
            source_id: r.source_id,
            target_id: r.target_id,
            properties: r.properties,
          })),
        });
        await this.store.flush();
        persistedRels += rels.length;
      };

      for (const event of concurrentPipeline) {
        if (cancelled) break;