Skip to content

Conversation

@Marenz
Copy link
Contributor

@Marenz Marenz commented Sep 11, 2024

  • Reset release notes
  • Send STOPPED message when duration is reached

Signed-off-by: Mathias L. Baumann <[email protected]>
@Marenz Marenz requested a review from a team as a code owner September 11, 2024 10:26
@Marenz Marenz requested a review from ktickner September 11, 2024 10:26
@github-actions github-actions bot added part:docs Affects the documentation part:tests Affects the unit, integration and performance (benchmarks) tests part:actor Affects the dispatching actor part:dispatcher Affects the high-level dispatcher interface labels Sep 11, 2024
_logger.info(
"Dispatch %s running for %s", dispatch.id, dispatch.duration
)
await asyncio.sleep(dispatch.duration.total_seconds())
Copy link
Contributor

Choose a reason for hiding this comment

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

Are you sure a sleep will work? Doesn't this block receiving/running any other dispatch while the current dispatch is running? Shouldn't you use timers instead or this code runs on a separate task for every dispatch that is currently running?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Yes ,currently we have one task for each dispatch running.

@Marenz Marenz added this pull request to the merge queue Sep 16, 2024
Merged via the queue into frequenz-floss:v0.x.x with commit 15e619f Sep 16, 2024
14 checks passed
@Marenz Marenz deleted the stopsig branch September 16, 2024 12:55
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

part:actor Affects the dispatching actor part:dispatcher Affects the high-level dispatcher interface part:docs Affects the documentation part:tests Affects the unit, integration and performance (benchmarks) tests

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants