orka.startup.cleanup module

Service Cleanup

This module handles cleanup and shutdown of OrKa services.

orka.startup.cleanup.cleanup_services(backend: str, processes: Dict[str, Popen] = None) None[source]

Clean up and stop services for the specified backend.

Parameters:
  • backend – The backend type (‘redis’, ‘redisstack’, ‘kafka’, or ‘dual’)

  • processes – Dictionary of running processes to terminate

orka.startup.cleanup.terminate_all_processes(processes: Dict[str, Popen]) None[source]

Terminate all managed processes gracefully.

Parameters:

processes – Dictionary of process names to process objects

orka.startup.cleanup.force_kill_processes(processes: Dict[str, Popen]) None[source]

Force kill all managed processes.

Parameters:

processes – Dictionary of process names to process objects

orka.startup.cleanup.cleanup_specific_backend(backend: str) None[source]

Clean up services specific to a backend type.

Parameters:

backend – The backend type (‘redis’, ‘redisstack’, ‘kafka’, or ‘dual’)