diff --git a/passerelle_reunion_fsn/models.py b/passerelle_reunion_fsn/models.py index 968618f..d6246af 100644 --- a/passerelle_reunion_fsn/models.py +++ b/passerelle_reunion_fsn/models.py @@ -123,6 +123,11 @@ class FSNReunionConnector(BaseResource): wcs_form_slug = models.CharField(max_length=256, blank=True, verbose_name=_('WCS form slug')) wcs_options = jsonfield.JSONField(null=True, blank=True) + def hourly(self): + self.logger.info('start fetch dossier') + dossiers = self._fetch_dossiers() + self.logger.info('num new dossiers fetched: %s' % len(dossiers)) + # def daily(self): # self.logger.info('start generate batch') # for batch in self._generate_batches(): @@ -354,13 +359,8 @@ query getDossiers($demarcheNumber: Int!, $createdSince: ISO8601DateTime, $first: 'data': self._ds_get_dossiers() } - def hourly(self): - self.logger.info('start fetch dossier') - dossiers = self._fetch_dossiers() - self.logger.info('num new dossiers fetched: %s' % len(dossiers)) - @endpoint( - methods=['get'], perm='can_access', name='fetch-dossiers', + methods=['post'], perm='can_access', name='fetch-dossiers', description=_('Fetch dossiers from DS and consolidate into local data') ) def fetch_dossiers(self, request):