Commit 9d11129a authored by Paul Dardeau's avatar Paul Dardeau
Browse files

Corrected build of message for StartBatch and AbortBatch.

parent 10e84526

kinetic/operations.py

+4 −2
Original line number Diff line number Diff line
@@ -308,7 +308,8 @@ class P2pPipedPush(BaseOperation): 
class StartBatch(BaseOperation):



    def _build(self):

        return _buildMessage(self.m, messages.Command.START_BATCH, '')

        self.m.header.messageType = messages.Command.START_BATCH

        return (self.m, None)





class EndBatch(BaseOperation):
@@ -329,7 +330,8 @@ class EndBatch(BaseOperation): 
class AbortBatch(BaseOperation):



    def _build(self):

        return _buildMessage(self.m, messages.Command.ABORT_BATCH, '')

        self.m.header.messageType = messages.Command.ABORT_BATCH

        return (self.m, None)





class Flush(BaseOperation):