sjs/vdirsyncer
1
0
Fork 0
mirror of https://github.com/samsonjs/vdirsyncer.git synced 2026-04-27 14:57:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Improve logging for sync

Browse source
This commit is contained in:
Markus Unterwaditzer 2016-10-03 19:15:21 +02:00
parent 827299ef24
commit 51063f09a6
1 changed files with 6 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
vdirsyncer/sync.py
View file

@ -282,8 +282,6 @@ class Action:
return return
else: else:
assert partial_sync == 'revert' assert partial_sync == 'revert'
sync_logger.warning('{} is read-only. Reverting change on '
'next sync.'.format(self.dest.storage))
self._run_impl(a, b) self._run_impl(a, b)
@ -310,12 +308,12 @@ class Upload(Action):
self.dest = dest self.dest = dest
def _run_impl(self, a, b): def _run_impl(self, a, b):
sync_logger.info(u'Copying (uploading) item {} to {}'
.format(self.ident, self.dest.storage))
if self.dest.storage.read_only: if self.dest.storage.read_only:
href = etag = None href = etag = None
else: else:
sync_logger.info(u'Copying (uploading) item {} to {}'
.format(self.ident, self.dest.storage))
href, etag = self.dest.storage.upload(self.item) href, etag = self.dest.storage.upload(self.item)
assert self.ident not in self.dest.new_status assert self.ident not in self.dest.new_status
@ -333,12 +331,12 @@ class Update(Action):
self.dest = dest self.dest = dest
def _run_impl(self, a, b): def _run_impl(self, a, b):
sync_logger.info(u'Copying (updating) item {} to {}'
.format(self.ident, self.dest.storage))
if self.dest.storage.read_only: if self.dest.storage.read_only:
href = etag = None href = etag = None
else: else:
sync_logger.info(u'Copying (updating) item {} to {}'
.format(self.ident, self.dest.storage))
meta = self.dest.new_status[self.ident] meta = self.dest.new_status[self.ident]
href = meta['href'] href = meta['href']
etag = self.dest.storage.update(href, self.item, meta['etag']) etag = self.dest.storage.update(href, self.item, meta['etag'])
@ -357,11 +355,10 @@ class Delete(Action):
self.dest = dest self.dest = dest
def _run_impl(self, a, b): def _run_impl(self, a, b):
sync_logger.info(u'Deleting item {} from {}'
.format(self.ident, self.dest.storage))
meta = self.dest.new_status[self.ident] meta = self.dest.new_status[self.ident]
if not self.dest.storage.read_only: if not self.dest.storage.read_only:
sync_logger.info(u'Deleting item {} from {}'
.format(self.ident, self.dest.storage))
self.dest.storage.delete(meta['href'], meta['etag']) self.dest.storage.delete(meta['href'], meta['etag'])
del self.dest.new_status[self.ident] del self.dest.new_status[self.ident]