Skip to content
This repository was archived by the owner on Jun 20, 2025. It is now read-only.

Schedule next iteration only when previous completed #69

Merged
merged 4 commits into from
Aug 8, 2018

Conversation

snripa
Copy link

@snripa snripa commented Aug 8, 2018

No description provided.

…completed (no blocking).

If multiple tasks per tick are executed, handle errors separately.
segabriel
segabriel previously approved these changes Aug 8, 2018
.messageRate(10_000)
.rampUpDuration(Duration.ofSeconds(15))
.executionTaskDuration(Duration.ofSeconds(30))
.injectors(5)
Copy link
Contributor

Choose a reason for hiding this comment

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

@snripa are we good with 5 instead of 1K?

Copy link
Contributor

Choose a reason for hiding this comment

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

@aharonha it was just for mnual sanity test, we can put whatever convenient is for us.

@snripa snripa force-pushed the scheduleNextIterationOnlyWhenPreviousCompleted branch from b516d2b to dcfcc8e Compare August 8, 2018 11:23
artem-v
artem-v previously approved these changes Aug 8, 2018
return Mono.just(rampUpIteration);
},

// job
state -> (iteration, userId) -> {
// System.out.println(LocalDateTime.now() + " User: " + userId + " | iteration: " + iteration);
;
System.out.println(LocalDateTime.now() + " User: " + userId + " | iteration: " + iteration);;
Copy link
Contributor

Choose a reason for hiding this comment

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

Remove one ;

@artem-v artem-v merged commit c6c69d1 into develop Aug 8, 2018
@artem-v artem-v deleted the scheduleNextIterationOnlyWhenPreviousCompleted branch August 8, 2018 12:25
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants