Function resolveExistingEntrypoint

packages/python/src/subscribers.ts:188–202

(
  workPath: string,
  filePath: string
)

}

async function resolveExistingEntrypoint(
  workPath: string,
  filePath: string
): Promise<string | null> {
  const candidates = [filePath, filePath.replace(/\.py$/i, '/__init__.py')];
  for (const candidate of candidates) {
    try {
      const stat = await fs.promises.stat(join(workPath, candidate));
      if (stat.isFile()) {
        return candidate;
      }
    } catch {}
  }
  return null;
}

function parseTopics(name: string, value: unknown): string[] {
  if (!Array.isArray(value) || value.length === 0) {