Skip to content

Conversation

@amuraru
Copy link

@amuraru amuraru commented Jan 7, 2026

Replace context.TODO() with the proper context parameter in three locations:

  • pkg/resources/kafka/kafka.go: reconcileKafkaPodDelete() now uses ctx for List() and CruiseControlScalerFactory()
  • internal/alertmanager/currentalert/process.go: downScale() now uses ctx for NewCruiseControlScaler()

This fix enables:

  • Proper cancellation propagation when operations need to be stopped
  • Better observability (tracing, logging) through context values
  • Prevention of potential resource leaks from uncancelable operations

Resolves FIXME comments in both files.

Replace context.TODO() with the proper context parameter in three locations:
- pkg/resources/kafka/kafka.go: reconcileKafkaPodDelete() now uses ctx for List() and CruiseControlScalerFactory()
- internal/alertmanager/currentalert/process.go: downScale() now uses ctx for NewCruiseControlScaler()

This fix enables:
- Proper cancellation propagation when operations need to be stopped
- Better observability (tracing, logging) through context values
- Prevention of potential resource leaks from uncancelable operations

Resolves FIXME comments in both files.
@amuraru amuraru force-pushed the claude/find-fix-bug-mk3xtsgbbicrcygn-sHxii branch from aaf5bf0 to 28d5365 Compare January 7, 2026 18:45
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants