Skip to content

Commit

Permalink
Rename variables
Browse files Browse the repository at this point in the history
  • Loading branch information
BenTalese committed Dec 12, 2023
1 parent 8965254 commit fb767e7
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions src/clapy/engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -107,9 +107,9 @@ async def invoke_usecase_async(
'''
_Pipeline = await self._pipeline_factory.create_pipeline_async(input_port, pipeline_configuration)

_PipelineShouldContinue = True
_PipelineRanWithoutFailure = True
while _PipelineShouldContinue and len(_Pipeline) > 0:
_CanContinueToNextPipe = True
_PipelineHasNoFailures = True
while _CanContinueToNextPipe and len(_Pipeline) > 0:

_Pipe = _Pipeline.pop(0)

Expand All @@ -128,10 +128,10 @@ async def invoke_usecase_async(
for pipe_config in pipeline_configuration
if issubclass(type(_Pipe), pipe_config.type))

_PipelineShouldContinue = (not _Pipe.has_failures and _PipelineRanWithoutFailure) or _ShouldIgnoreFailures # type: ignore
_PipelineRanWithoutFailure = (not _Pipe.has_failures and _PipelineRanWithoutFailure)
_CanContinueToNextPipe = (not _Pipe.has_failures and _PipelineHasNoFailures) or _ShouldIgnoreFailures # type: ignore
_PipelineHasNoFailures = (not _Pipe.has_failures and _PipelineHasNoFailures)

return _PipelineRanWithoutFailure
return _PipelineHasNoFailures


class Engine:
Expand Down

0 comments on commit fb767e7

Please sign in to comment.