diff --git a/amazon_kclpy/kcl.py b/amazon_kclpy/kcl.py index bb6896c..90ad23a 100644 --- a/amazon_kclpy/kcl.py +++ b/amazon_kclpy/kcl.py @@ -220,7 +220,6 @@ def shutdown(self, checkpointer, reason): ''' raise NotImplementedError - @abc.abstractmethod def shutdown_requested(self, checkpointer): """ Called by a KCLProcess instance to indicate that this record processor is about to be be shutdown. This gives diff --git a/amazon_kclpy/v2/processor.py b/amazon_kclpy/v2/processor.py index 1c4193f..363ba68 100644 --- a/amazon_kclpy/v2/processor.py +++ b/amazon_kclpy/v2/processor.py @@ -73,7 +73,6 @@ def shutdown(self, shutdown_input): """ raise NotImplementedError - @abc.abstractmethod def shutdown_requested(self, shutdown_requested_input): """ Called by a KCLProcess instance to indicate that this record processor is about to be be shutdown. This gives