Skip to content

Make silent-empty discovery loud #405

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
khaliqgant wants to merge 2 commits into from
Closed

Make silent-empty discovery loud #405

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
54bfd3f
fix: surface persistent empty discovery
khaliqgant Aug 26, 2026
23d0b51
fix: recheck discovery epoch after index reads
khaliqgant Aug 26, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
124 changes: 124 additions & 0 deletions src/orchestrator/factory.test.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5783,6 +5783,130 @@ describe('FactoryLoop', () => {
}
})

it('classifies an authoritative empty GitHub index without inventing tree reads', async () => {
const root = await mkdtemp(join(tmpdir(), 'factory-empty-index-signal-'))
const mount = new CountingListTreeMount({
'/github/repos/AgentWorkforce/pear/issues/_index.json': [],
})
const factory = createFactory(config({
issueSource: 'github',
safety: { requireLabel: 'factory', requireTitlePrefix: '[factory]' },
loop: { registryPath: join(root, 'registry.json'), heartbeatPath: join(root, 'heartbeat.json') },
}), {
mount,
fleet: new RemoteLifecycleFleetClient(),
triage: new StaticTriage(),
githubWriteback: new RecordingGithubWriteback(),
})
try {
await factory.start({ mode: 'live', liveSubscription: { transport: 'subscribe', reconcileIntervalMs: 600_000 } })
expect(factory.status().readinessReconcile).toMatchObject({
candidates: 0,
treeReads: 0,
discoveryReposConfigured: 1,
discoveryIndexRepos: 1,
discoveryIndexEmptyRepos: 1,
discoveryCacheRepos: 0,
discoveryTreeRepos: 0,
consecutiveEmptySweeps: 1,
emptySweepWarningThreshold: 3,
})
expect(mount.listTreePrefixes).toEqual([])
} finally {
await factory.stop()
await rm(root, { recursive: true, force: true })
}
})

it('warns once after three cache-backed empty sweeps with zero tree reads', async () => {
const root = await mkdtemp(join(tmpdir(), 'factory-empty-cache-signal-'))
const mount = new CountingListTreeMount()
mount.emit(changeEvent('/factory/observability/mount-health/current.json', 'event-empty-cache'))
const stateStore = new InMemoryStateStore({ batchSize: 2 })
const make = (logger: { warn?: (message: string, details?: unknown) => void } = {}) => createFactory(config({
issueSource: 'github',
safety: { requireLabel: 'factory', requireTitlePrefix: '[factory]' },
loop: { registryPath: join(root, 'registry.json'), heartbeatPath: join(root, 'heartbeat.json') },
}), {
mount,
fleet: new RemoteLifecycleFleetClient(),
stateStore,
triage: new StaticTriage(),
githubWriteback: new RecordingGithubWriteback(),
logger,
})
try {
const seed = make()
expect((await seed.runOnce()).pulled).toEqual([])
await seed.stop()
expect(mount.listTreePrefixes).toHaveLength(2)
mount.listTreePrefixes.length = 0

const warnings: Array<{ message: string; details?: unknown }> = []
const factory = make({ warn: (message, details) => warnings.push({ message, details }) })
await factory.start({ mode: 'live', liveSubscription: { transport: 'subscribe', reconcileIntervalMs: 100 } })
await vi.waitFor(() => expect(factory.status().readinessReconcile?.consecutiveEmptySweeps).toBe(3), {
timeout: 5_000,
})
await factory.stop()
expect(factory.status().readinessReconcile).toMatchObject({
candidates: 0,
treeReads: 0,
emptyTreeReads: 0,
discoveryReposConfigured: 1,
discoveryIndexRepos: 0,
discoveryCacheRepos: 1,
discoveryCacheEmptyRepos: 1,
discoveryTreeRepos: 0,
emptySweepWarningThreshold: 3,
})
expect(factory.status().counters).toMatchObject({
readinessZeroCandidateRepoSweeps: 3,

@cubic-dev-ai cubic-dev-ai Bot Aug 26, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

P2: The waitFor on consecutiveEmptySweeps === 3 leaves the live sweep running at a 100ms interval; a fourth empty sweep that completes before stop() drains the in-flight pass bumps the counters to 4, making the exact toEqual-style readinessZeroCandidateRepoSweeps: 3 assertions flaky under CI load. Stop the factory as soon as the streak is observed and make the counter assertions tolerant (>= 3), or assert only the robust readinessPersistentEmptyDiscoveryWarnings: 1 and the single warning entry.

Prompt for AI agents 
Check if this issue is valid — if so, understand the root cause and fix it. At src/orchestrator/factory.test.ts, line 5864:

<comment>The `waitFor` on `consecutiveEmptySweeps === 3` leaves the live sweep running at a 100ms interval; a fourth empty sweep that completes before `stop()` drains the in-flight pass bumps the counters to 4, making the exact `toEqual`-style `readinessZeroCandidateRepoSweeps: 3` assertions flaky under CI load. Stop the factory as soon as the streak is observed and make the counter assertions tolerant (>= 3), or assert only the robust `readinessPersistentEmptyDiscoveryWarnings: 1` and the single warning entry.</comment>

<file context>
@@ -5783,6 +5783,130 @@ describe('FactoryLoop', () => {
+        emptySweepWarningThreshold: 3,
+      })
+      expect(factory.status().counters).toMatchObject({
+        readinessZeroCandidateRepoSweeps: 3,
+        readinessZeroTreeReadRepoSweeps: 3,
+        readinessCacheEmptyRepoSweeps: 3,
</file context>

readinessZeroTreeReadRepoSweeps: 3,
readinessCacheEmptyRepoSweeps: 3,
readinessPersistentEmptyDiscoveryWarnings: 1,
})
expect(mount.listTreePrefixes).toEqual([])
expect(warnings.filter((entry) => entry.message.includes('persistently produced zero candidates'))).toEqual([
expect.objectContaining({ details: expect.objectContaining({ consecutiveEmptySweeps: 3, cacheEmptyRepos: 1, treeReads: 0 }) }),
])
} finally {
await rm(root, { recursive: true, force: true })
}
})

it('classifies a genuinely empty uncached tree separately from zero reads', async () => {
const root = await mkdtemp(join(tmpdir(), 'factory-empty-tree-signal-'))
const mount = new CountingListTreeMount()
const factory = createFactory(config({
issueSource: 'github',
safety: { requireLabel: 'factory', requireTitlePrefix: '[factory]' },
loop: { registryPath: join(root, 'registry.json'), heartbeatPath: join(root, 'heartbeat.json') },
}), {
mount,
fleet: new RemoteLifecycleFleetClient(),
triage: new StaticTriage(),
githubWriteback: new RecordingGithubWriteback(),
})
try {
await factory.start({ mode: 'live', liveSubscription: { transport: 'subscribe', reconcileIntervalMs: 600_000 } })
expect(factory.status().readinessReconcile).toMatchObject({
candidates: 0,
treeReads: 2,
emptyTreeReads: 2,
discoveryReposConfigured: 1,
discoveryIndexRepos: 0,
discoveryCacheRepos: 0,
discoveryTreeRepos: 1,
discoveryTreeEmptyRepos: 1,
})
expect(mount.listTreePrefixes).toHaveLength(2)
} finally {
await factory.stop()
await rm(root, { recursive: true, force: true })
}
})

it('retains the durable GitHub tree fallback when the issue index is malformed', async () => {
const root = await mkdtemp(join(tmpdir(), 'factory-github-index-cache-fallback-'))
const indexPath = '/github/repos/AgentWorkforce/pear/issues/_index.json'
Expand Down
147 changes: 146 additions & 1 deletion src/orchestrator/factory.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -548,6 +548,9 @@ const RELAYFILE_OPERATION_BACKSTOP_RATIO = 1.25
const DISCOVERY_SWEEP_LEASE_MS = 5 * 60_000
const DISCOVERY_SWEEP_RENEW_MS = 30_000
const READINESS_RECONCILE_FAILURE_THRESHOLD = 3
// Three clean passes filters one-off empty indexes/checkpoints while making a
// silent discovery outage loud within two normal intervals after first sight.
const EMPTY_DISCOVERY_WARNING_THRESHOLD = 3

/**
* A relayfile fault a swallowing catch must not turn into "no result".
Expand Down Expand Up @@ -1006,6 +1009,7 @@ export class FactoryLoop implements Factory {
#readinessReconcileAbandonedWait?: Promise<void>
#readinessReconcileAbandonedSinceMs?: number
#readinessReconcileConsecutiveFailures = 0
#readinessReconcileConsecutiveEmptySweeps = 0
#readinessReconcileLastDurationMs?: number
#readinessReconcileLastStartedAtMs?: number
#readinessReconcileLastCompletedAtMs?: number
Expand All @@ -1029,6 +1033,13 @@ export class FactoryLoop implements Factory {
/** Served tree reads, and how many were empty. Held even at zero. */
treeReads: number
emptyTreeReads: number
discoveryReposConfigured: number
discoveryIndexRepos: number
discoveryIndexEmptyRepos: number
discoveryCacheRepos: number
discoveryCacheEmptyRepos: number
discoveryTreeRepos: number
discoveryTreeEmptyRepos: number
dispatched: number
skipped: number
skipReasons: Partial<Record<FactorySweepSkipReasonCode, number>>
Expand Down Expand Up @@ -1191,6 +1202,20 @@ export class FactoryLoop implements Factory {
#discoverySweepTreeReads = 0
/** How many of those were served with zero entries. */
#discoverySweepEmptyTreeReads = 0
#discoverySweepReposConfigured = 0
#discoverySweepIndexRepos = 0
#discoverySweepIndexEmptyRepos = 0
#discoverySweepCacheRepos = 0
#discoverySweepCacheEmptyRepos = 0
#discoverySweepTreeRepos = 0
#discoverySweepTreeEmptyRepos = 0
readonly #discoverySweepConfiguredRepoKeys = new Set<string>()
readonly #discoverySweepIndexRepoKeys = new Set<string>()
readonly #discoverySweepIndexEmptyRepoKeys = new Set<string>()
readonly #discoverySweepCacheRepoKeys = new Set<string>()
readonly #discoverySweepCacheEmptyRepoKeys = new Set<string>()
readonly #discoverySweepTreeRepoKeys = new Set<string>()
readonly #discoverySweepTreeEmptyRepoKeys = new Set<string>()
/**
* The longest `Retry-After` any operation in this sweep advertised.
*
Expand Down Expand Up @@ -2415,6 +2440,17 @@ export class FactoryLoop implements Factory {
skipReasons: factorySweepSkipReasonCounts(report.skipped),
dispatchFailures: report.skipped.filter((entry) => entry.code === 'dispatch-failed').length,
dispatchFailureReasons: factoryDispatchFailureReasonCounts(report.skipped),
discoveryReposConfigured: report.discoveryReposConfigured ?? 0,
discoveryIndexRepos: report.discoveryIndexRepos ?? 0,
discoveryIndexEmptyRepos: report.discoveryIndexEmptyRepos ?? 0,
discoveryCacheRepos: report.discoveryCacheRepos ?? 0,
discoveryCacheEmptyRepos: report.discoveryCacheEmptyRepos ?? 0,
discoveryTreeRepos: report.discoveryTreeRepos ?? 0,
discoveryTreeEmptyRepos: report.discoveryTreeEmptyRepos ?? 0,
treeReads: report.treeReads ?? 0,
emptyTreeReads: report.emptyTreeReads ?? 0,
consecutiveEmptySweeps: this.#readinessReconcileConsecutiveEmptySweeps,
emptySweepWarningThreshold: EMPTY_DISCOVERY_WARNING_THRESHOLD,
discoveryDeferred: report.discoveryDeferred,
})
} catch (error) {
Expand Down Expand Up @@ -3389,6 +3425,14 @@ export class FactoryLoop implements Factory {
this.#discoverySweepOverloads = 0
this.#discoverySweepTreeReads = 0
this.#discoverySweepEmptyTreeReads = 0
this.#discoverySweepReposConfigured = 0
this.#discoverySweepIndexRepos = 0
this.#discoverySweepIndexEmptyRepos = 0
this.#discoverySweepCacheRepos = 0
this.#discoverySweepCacheEmptyRepos = 0
this.#discoverySweepTreeRepos = 0
this.#discoverySweepTreeEmptyRepos = 0
this.#clearDiscoveryRepoSignals()
this.#discoverySweepRetryAfterSeconds = undefined
this.#discoverySweepProgress = false
this.#startDiscoverySweepRenewal(claim.lease.epoch)
Expand Down Expand Up @@ -3489,6 +3533,14 @@ export class FactoryLoop implements Factory {
this.#discoverySweepOverloads = 0
this.#discoverySweepTreeReads = 0
this.#discoverySweepEmptyTreeReads = 0
this.#discoverySweepReposConfigured = 0
this.#discoverySweepIndexRepos = 0
this.#discoverySweepIndexEmptyRepos = 0
this.#discoverySweepCacheRepos = 0
this.#discoverySweepCacheEmptyRepos = 0
this.#discoverySweepTreeRepos = 0
this.#discoverySweepTreeEmptyRepos = 0
this.#clearDiscoveryRepoSignals()
this.#discoverySweepRetryAfterSeconds = undefined
this.#discoverySweepProgress = false
// This sweep is over either way (committed, deferred, or lease lost) —
Expand Down Expand Up @@ -4013,6 +4065,13 @@ export class FactoryLoop implements Factory {
// is still inside that try, so the counts are this sweep's own.
treeReads: this.#discoverySweepTreeReads,
emptyTreeReads: this.#discoverySweepEmptyTreeReads,
discoveryReposConfigured: this.#discoverySweepReposConfigured,
discoveryIndexRepos: this.#discoverySweepIndexRepos,
discoveryIndexEmptyRepos: this.#discoverySweepIndexEmptyRepos,
discoveryCacheRepos: this.#discoverySweepCacheRepos,
discoveryCacheEmptyRepos: this.#discoverySweepCacheEmptyRepos,
discoveryTreeRepos: this.#discoverySweepTreeRepos,
discoveryTreeEmptyRepos: this.#discoverySweepTreeEmptyRepos,
slackDegraded: this.#slackDegraded,
...(orphanRecoveryDegraded ? { orphanRecoveryDegraded } : {}),
}
Expand Down Expand Up @@ -6216,10 +6275,47 @@ export class FactoryLoop implements Factory {
return
}
this.#readinessReconcileLastSweepDeferred = undefined
const configuredRepos = report.discoveryReposConfigured ?? 0
if (configuredRepos > 0 && report.pulled.length === 0) {

@cubic-dev-ai cubic-dev-ai Bot Aug 26, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

P2: When issueSource is linear, a non-empty GitHub index can create a mirror while the current Linear tree still has no ready issue. This condition then counts that pass as empty and can emit the three-sweep warning; track GitHub candidates separately or restrict this alarm to the native GitHub discovery path.

Prompt for AI agents 
Check if this issue is valid — if so, understand the root cause and fix it. At src/orchestrator/factory.ts, line 6279:

<comment>When `issueSource` is `linear`, a non-empty GitHub index can create a mirror while the current Linear tree still has no ready issue. This condition then counts that pass as empty and can emit the three-sweep warning; track GitHub candidates separately or restrict this alarm to the native GitHub discovery path.</comment>

<file context>
@@ -6216,10 +6275,47 @@ export class FactoryLoop implements Factory {
     }
     this.#readinessReconcileLastSweepDeferred = undefined
+    const configuredRepos = report.discoveryReposConfigured ?? 0
+    if (configuredRepos > 0 && report.pulled.length === 0) {
+      this.#readinessReconcileConsecutiveEmptySweeps += 1
+      this.#increment('readinessZeroCandidateRepoSweeps')
</file context>

this.#readinessReconcileConsecutiveEmptySweeps += 1

@cubic-dev-ai cubic-dev-ai Bot Aug 26, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

P2: When a reconciliation fails between empty passes, the streak remains unchanged, so two later empty successes can trigger the three-sweep warning without three consecutive successful empty sweeps. Reset #readinessReconcileConsecutiveEmptySweeps in the reconciliation failure path.

Prompt for AI agents 
Check if this issue is valid — if so, understand the root cause and fix it. At src/orchestrator/factory.ts, line 6280:

<comment>When a reconciliation fails between empty passes, the streak remains unchanged, so two later empty successes can trigger the three-sweep warning without three consecutive successful empty sweeps. Reset `#readinessReconcileConsecutiveEmptySweeps` in the reconciliation failure path.</comment>

<file context>
@@ -6216,10 +6275,47 @@ export class FactoryLoop implements Factory {
     this.#readinessReconcileLastSweepDeferred = undefined
+    const configuredRepos = report.discoveryReposConfigured ?? 0
+    if (configuredRepos > 0 && report.pulled.length === 0) {
+      this.#readinessReconcileConsecutiveEmptySweeps += 1
+      this.#increment('readinessZeroCandidateRepoSweeps')
+      if ((report.treeReads ?? 0) === 0) this.#increment('readinessZeroTreeReadRepoSweeps')
</file context>

this.#increment('readinessZeroCandidateRepoSweeps')
if ((report.treeReads ?? 0) === 0) this.#increment('readinessZeroTreeReadRepoSweeps')
if ((report.discoveryIndexEmptyRepos ?? 0) > 0) this.#increment('readinessIndexEmptyRepoSweeps')
if ((report.discoveryCacheEmptyRepos ?? 0) > 0) this.#increment('readinessCacheEmptyRepoSweeps')
if ((report.discoveryTreeEmptyRepos ?? 0) > 0) this.#increment('readinessTreeEmptyRepoSweeps')
// Warn only on the threshold crossing. A legitimately idle workspace
// remains observable through the streak, but does not emit once a minute
// forever. A later non-empty pass resets the edge and permits a new warn.
if (this.#readinessReconcileConsecutiveEmptySweeps === EMPTY_DISCOVERY_WARNING_THRESHOLD) {
this.#increment('readinessPersistentEmptyDiscoveryWarnings')
this.#logger.warn?.('[factory] discovery has persistently produced zero candidates for configured repositories', {
consecutiveEmptySweeps: this.#readinessReconcileConsecutiveEmptySweeps,
warningThreshold: EMPTY_DISCOVERY_WARNING_THRESHOLD,
configuredRepos,
indexRepos: report.discoveryIndexRepos ?? 0,
indexEmptyRepos: report.discoveryIndexEmptyRepos ?? 0,
cacheRepos: report.discoveryCacheRepos ?? 0,
cacheEmptyRepos: report.discoveryCacheEmptyRepos ?? 0,
treeRepos: report.discoveryTreeRepos ?? 0,
treeEmptyRepos: report.discoveryTreeEmptyRepos ?? 0,
treeReads: report.treeReads ?? 0,
emptyTreeReads: report.emptyTreeReads ?? 0,
})
}
} else {
this.#readinessReconcileConsecutiveEmptySweeps = 0
}
this.#readinessReconcileLastSweep = {
candidates: report.pulled.length,
treeReads: report.treeReads ?? 0,
emptyTreeReads: report.emptyTreeReads ?? 0,
discoveryReposConfigured: configuredRepos,
discoveryIndexRepos: report.discoveryIndexRepos ?? 0,
discoveryIndexEmptyRepos: report.discoveryIndexEmptyRepos ?? 0,
discoveryCacheRepos: report.discoveryCacheRepos ?? 0,
discoveryCacheEmptyRepos: report.discoveryCacheEmptyRepos ?? 0,
discoveryTreeRepos: report.discoveryTreeRepos ?? 0,
discoveryTreeEmptyRepos: report.discoveryTreeEmptyRepos ?? 0,
dispatched: report.dispatched.length,
skipped: report.skipped.length,
skipReasons: factorySweepSkipReasonCounts(report.skipped),
Expand Down Expand Up @@ -6339,6 +6435,15 @@ export class FactoryLoop implements Factory {
// an empty workspace, not a silent mount (#351 follow-up).
treeReads: this.#readinessReconcileLastSweep.treeReads,
emptyTreeReads: this.#readinessReconcileLastSweep.emptyTreeReads,
discoveryReposConfigured: this.#readinessReconcileLastSweep.discoveryReposConfigured,
discoveryIndexRepos: this.#readinessReconcileLastSweep.discoveryIndexRepos,
discoveryIndexEmptyRepos: this.#readinessReconcileLastSweep.discoveryIndexEmptyRepos,
discoveryCacheRepos: this.#readinessReconcileLastSweep.discoveryCacheRepos,
discoveryCacheEmptyRepos: this.#readinessReconcileLastSweep.discoveryCacheEmptyRepos,
discoveryTreeRepos: this.#readinessReconcileLastSweep.discoveryTreeRepos,
discoveryTreeEmptyRepos: this.#readinessReconcileLastSweep.discoveryTreeEmptyRepos,
consecutiveEmptySweeps: this.#readinessReconcileConsecutiveEmptySweeps,
emptySweepWarningThreshold: EMPTY_DISCOVERY_WARNING_THRESHOLD,
dispatched: this.#readinessReconcileLastSweep.dispatched,
skipped: this.#readinessReconcileLastSweep.skipped,
...(Object.keys(this.#readinessReconcileLastSweep.skipReasons).length > 0
Expand Down Expand Up @@ -9033,10 +9138,32 @@ export class FactoryLoop implements Factory {
return candidates
}

#clearDiscoveryRepoSignals(): void {
this.#discoverySweepConfiguredRepoKeys.clear()
this.#discoverySweepIndexRepoKeys.clear()
this.#discoverySweepIndexEmptyRepoKeys.clear()
this.#discoverySweepCacheRepoKeys.clear()
this.#discoverySweepCacheEmptyRepoKeys.clear()
this.#discoverySweepTreeRepoKeys.clear()
this.#discoverySweepTreeEmptyRepoKeys.clear()
}

async #githubIssuePaths(): Promise<string[]> {
try {
const issuePaths = new Map<string, string>()
for (const { owner, repo } of configuredGithubRepoParts(this.#config)) {
const repos = configuredGithubRepoParts(this.#config)
// Match #listRelayfileTree's two load-bearing scopes: this method is also
// used by point lookups and startup work, so only the enumeration call
// issued by the currently leased pass may contribute to its diagnosis.
const issuingPass = discoveryEnumerationPass.getStore()
const recordsCurrentDiscovery = (): boolean =>
issuingPass !== undefined && issuingPass.epoch === this.#discoverySweepEpoch
if (recordsCurrentDiscovery()) {
for (const { owner, repo } of repos) this.#discoverySweepConfiguredRepoKeys.add(`${owner}/${repo}`)
this.#discoverySweepReposConfigured = this.#discoverySweepConfiguredRepoKeys.size
}
for (const { owner, repo } of repos) {
const repoKey = `${owner}/${repo}`
const roots = githubIssueRepoRoots(owner, repo)
const cachedBatches = roots.map((root) => this.#cachedDiscoveryTree(root))
const allRootsCached = cachedBatches.every((paths): paths is string[] => paths !== undefined)
Expand All @@ -9060,15 +9187,33 @@ export class FactoryLoop implements Factory {
// comment-replay call sites that share this cache.
pathBatches = [indexedPaths]
this.#increment('githubIssueIndexReposUsed')
if (recordsCurrentDiscovery()) {
this.#discoverySweepIndexRepoKeys.add(repoKey)
if (indexedPaths.length === 0) this.#discoverySweepIndexEmptyRepoKeys.add(repoKey)
this.#discoverySweepIndexRepos = this.#discoverySweepIndexRepoKeys.size
this.#discoverySweepIndexEmptyRepos = this.#discoverySweepIndexEmptyRepoKeys.size
}
} else if (allRootsCached) {
pathBatches = cachedBatches
this.#increment('githubIssueDiscoveryCacheReposUsed')
if (recordsCurrentDiscovery()) {
this.#discoverySweepCacheRepoKeys.add(repoKey)
if (cachedBatches.every((paths) => paths.length === 0)) this.#discoverySweepCacheEmptyRepoKeys.add(repoKey)
this.#discoverySweepCacheRepos = this.#discoverySweepCacheRepoKeys.size
this.#discoverySweepCacheEmptyRepos = this.#discoverySweepCacheEmptyRepoKeys.size
}
} else {
pathBatches = []
for (const root of roots) {
pathBatches.push(await this.#listRelayfileTree(root, 'GitHub issue ingestion', { cache: true, enumeration: true }))
}
this.#increment('githubIssueIndexFallbacks')
if (recordsCurrentDiscovery()) {
this.#discoverySweepTreeRepoKeys.add(repoKey)
if (pathBatches.every((paths) => paths.length === 0)) this.#discoverySweepTreeEmptyRepoKeys.add(repoKey)
this.#discoverySweepTreeRepos = this.#discoverySweepTreeRepoKeys.size
this.#discoverySweepTreeEmptyRepos = this.#discoverySweepTreeEmptyRepoKeys.size
}
}
for (const paths of pathBatches) {
for (let index = 0; index < paths.length; index += 1) {
Expand Down
Loading