Calculates a list of all the hours that should be deleted given the current hour of the day and the retentionperiod in hours Usually this is a list of all hours out of the 24 hours in the day - retention period - the current hour of the day.

Creates a new LabelSelector that selects all workflows that have the completed Label.

Creates a new selector that selects all completed workflows and workflows with completed hour label outside of the retention window.

Currently we only compare the lengths of finalizers.

Check if any finalizer is set.

This function creates a label selector, that will ignore all objects (in this case workflow) that DOES NOT have a label key=workflowTerminationStatusKey with a value=workflowTerminatedValue.

Check if the deletion timestamp is set, this is set automatically when an object is deleted.

NewController returns a new FlyteWorkflow controller.

Reset all the finalizers on the object.

Sets a new finalizer in case the finalizer is empty.

A BatchingWorkQueue consists of 2 queues and migrates items from sub-queue to parent queue as a batch at a specified interval.

Controller is the controller implementation for FlyteWorkflow resources.

Garbage collector is an active background cleanup service, that deletes all workflows that are completed and older than the configured TTL.

SimpleWorkQueue provides a simple RateLimitingInterface, but ensures that the compositeQueue interface works with a default queue.

A CompositeWorkQueue can be used in cases where the work is enqueued by two sources.