apunkt/ktx
1
0
Fork 0
mirror of https://github.com/Kaelio/ktx.git synced 2026-06-28 08:49:38 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat(cli): route ingest adapter logs through operational logger

Browse source
This commit is contained in:
Andrey Avtomonov 2026-05-12 01:35:19 +02:00
parent 20ac0329b8
commit 5cdae74825
12 changed files with 203 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

3
packages/cli/src/ingest.ts
View file

@ -27,6 +27,7 @@ import {
renderMemoryFlowTui,
startLiveMemoryFlowTui,
} from './memory-flow-tui.js';
import { createCliOperationalLogger } from './io/logger.js';
import { resolveVizFallback, warnVizFallbackOnce } from './viz-fallback.js';
import { profileMark } from './startup-profile.js';
@ -435,11 +436,13 @@ export async function runKtxIngest(
const executeLocalIngest = deps.runLocalIngest ?? runLocalIngest;
const localIngestOptions = deps.localIngestOptions ?? {};
const managedDaemon = managedDaemonOptionsForIngestRun(args, io);
const operationalLogger = createCliOperationalLogger(io, args.outputMode);
const adapterOptions = {
...(localIngestOptions.pullConfigOptions ?? {}),
...(args.databaseIntrospectionUrl ? { databaseIntrospectionUrl: args.databaseIntrospectionUrl } : {}),
...(managedDaemon ? { managedDaemon } : {}),
...(args.adapter === 'historic-sql' ? { historicSqlConnectionId: args.connectionId } : {}),
logger: operationalLogger,
};
if (args.adapter === 'metabase' && args.sourceDir) {
throw new Error('source-dir uploads are not supported for the Metabase fan-out adapter');