def clean_registries(queue):
 registry = FinishedJobRegistry(name=queue.name, connection=queue.connection)
 registry.cleanup()
 registry = StartedJobRegistry(name=queue.name, connection=queue.connection)
 registry.cleanup()

def clean_registries ( queue ) : registry = FinishedJobRegistry ( name = queue . name , connection = queue . connection ) registry . cleanup ( ) registry = StartedJobRegistry ( name = queue . name , connection = queue . connection ) registry . cleanup ( )
cleans startedjobregistry and finishedjobregistry of a queue .