super(SyncStep,self).__init__(**args)
return
- def call(self):
- pending = self.fetch_pending()
- failed = []
- for o in pending:
- if (not self.depends_on(o, failed)):
- try:
- self.sync_record(o)
- o.enacted = datetime.now() # Is this the same timezone? XXX
- o.save(update_fields=['enacted'])
- except:
- failed.append(o)
+
def __call__(self):