equal
deleted
inserted
replaced
842 assert not self._processed, """Trying to add data to a closed operation. |
842 assert not self._processed, """Trying to add data to a closed operation. |
843 Iterating over operation data closed it and should be reserved to precommit / |
843 Iterating over operation data closed it and should be reserved to precommit / |
844 postcommit method of the operation.""" |
844 postcommit method of the operation.""" |
845 _container_add(self._container, data) |
845 _container_add(self._container, data) |
846 |
846 |
|
847 def remove_data(self, data): |
|
848 assert not self._processed, """Trying to add data to a closed operation. |
|
849 Iterating over operation data closed it and should be reserved to precommit / |
|
850 postcommit method of the operation.""" |
|
851 self._container.remove(data) |
|
852 |
847 def get_data(self): |
853 def get_data(self): |
848 assert not self._processed, """Trying to get data from a closed operation. |
854 assert not self._processed, """Trying to get data from a closed operation. |
849 Iterating over operation data closed it and should be reserved to precommit / |
855 Iterating over operation data closed it and should be reserved to precommit / |
850 postcommit method of the operation.""" |
856 postcommit method of the operation.""" |
851 self._processed = True |
857 self._processed = True |