Skip to content

Commit

Permalink
Update logging
Browse files Browse the repository at this point in the history
  • Loading branch information
leszko committed Apr 18, 2024
1 parent af07417 commit 9421cb9
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions packages/api/src/controllers/stream.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1036,7 +1036,7 @@ app.put(
const { key = "pull.source", waitActive } = toStringValues(req.query);
const rawPayload = req.body as NewStreamPayload;

logger.info(`/pull request received for stream name=${rawPayload.name}`);
logger.info(`pull request received for stream name=${rawPayload.name}`);

const ingest = await getIngestBase(req);

Expand Down Expand Up @@ -1090,15 +1090,15 @@ app.put(
let stream: DBStream;
if (!streamExisted) {
logger.info(
`/pull request creating a new stream with name=${rawPayload.name}`
`pull request creating a new stream with name=${rawPayload.name}`
);
stream = await handleCreateStream(req);
stream.pullRegion = pullRegion;
await db.stream.replace(stream);
} else {
const oldStream = streams[0];
logger.info(
`/pull reusing existing old stream with id=${oldStream.id} name=${oldStream.name}`
`pull reusing existing old stream with id=${oldStream.id} name=${oldStream.name}`
);
const sleepFor = terminateDelay(oldStream);
if (sleepFor > 0) {
Expand Down

0 comments on commit 9421cb9

Please sign in to comment.