Skip to content
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.

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

Add log message when pipe is skipped #6550

Merged
merged 3 commits into from
Apr 2, 2024

Conversation

nielsm5
Copy link
Sponsor Member

@nielsm5 nielsm5 commented Mar 30, 2024

No description provided.

@nielsm5 nielsm5 linked an issue Mar 30, 2024 that may be closed by this pull request
@nielsm5 nielsm5 added the 7.9 label Mar 30, 2024
@@ -103,6 +103,7 @@ protected PipeRunResult processPipe(PipeLine pipeLine, IPipe pipe, Message messa
if (pipe instanceof FixedForwardPipe) {
FixedForwardPipe ffPipe = (FixedForwardPipe) pipe;
if (ffPipe.skipPipe(message, pipeLineSession)) {
log.info("skipping pipe [{}] because of empty input", pipe::getName);
Copy link
Contributor

Choose a reason for hiding this comment

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

Het log statement op deze plek klopt niet helemaal met de controle dat uitgevoerd wordt in de skipPipe methode..

De skip on empty & is not empty check is slechts één van de meerdere redenen waarom deze methode true zou kunnen retourneren..

Copy link
Sponsor Member Author

Choose a reason for hiding this comment

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

Klopt ik zag het ook. Ben er nog niet helemaal over uit of ik een nieuwe processor wil maken of überhaupt de code wil verplaatsen.
Het zit nu iig best raar in elkaar. Voor de 7.9 en 8.0 moeten we denk ik de log regel verplaatsen naar daar waar de checks worden gedaan.

@nielsm5 nielsm5 merged commit 1503c55 into 7.9-release Apr 2, 2024
11 checks passed
@nielsm5 nielsm5 deleted the issue/7.9/add-log-when-pipe-skipped branch April 2, 2024 09:04
@@ -385,7 +385,7 @@
<dependency>
<groupId>com.github.mwiede</groupId>
<artifactId>jsch</artifactId>
<version>0.2.14</version>
<version>0.2.15</version>
Copy link
Contributor

Choose a reason for hiding this comment

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

Oh, durf je dit hier toch wel aan? Prima op zich. Had het teruggedraaid in mijn PRs.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

empty message not empty when ApiListener is streaming the message.
4 participants