Skip to content

Commit

Permalink
improve code quality
Browse files Browse the repository at this point in the history
  • Loading branch information
Revolution1 committed May 7, 2019
1 parent e305fd4 commit 245565a
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 3 deletions.
2 changes: 1 addition & 1 deletion etcd3/apis/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,5 +15,5 @@ def _get(self, url, **kwargs):
def _post(self, url, data=None, json=None, **kwargs):
raise NotImplementedError

def call_rpc(self, method, data=None, stream=False, **kwargs):
def call_rpc(self, method, data=None, stream=False, encode=True, raw=False, **kwargs):
raise NotImplementedError
3 changes: 2 additions & 1 deletion etcd3/stateful/watch.py
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,8 @@ def request_cancel(self): # pragma: no cover
# return self.client.watch_cancel(watch_id=self.watch_id)
pass

def get_filter(self, filter):
@staticmethod
def get_filter(filter):
"""
Get the event filter function
Expand Down
2 changes: 1 addition & 1 deletion etcd3/swagger_helper.py
Original file line number Diff line number Diff line change
Expand Up @@ -347,7 +347,7 @@ def encode(self, data):
if 'properties' not in self._node:
return {}
rt = {}
for k, v in self.properties._items():
for k in self.properties._keys():
value = self.properties._get(k).encode(data.get(k))
if value is None:
continue
Expand Down

0 comments on commit 245565a

Please sign in to comment.