Correctly set _import_in_progress

This commit is contained in:
Romuald Bierbasz
2019-12-05 11:39:09 +01:00
parent 453cd1cc70
commit 00164fab67

View File

@@ -58,8 +58,6 @@ class Importer:
if self._import_in_progress:
raise ImportInProgress()
context = await self._prepare_context(ids)
async def import_element(id_, context_):
try:
element = await self._get(id_, context_)
@@ -83,12 +81,17 @@ class Importer:
finally:
self._import_in_progress = False
self._task_manager.create_task(
import_elements(ids, context),
"{} import".format(self._name),
handle_exceptions=False
)
self._import_in_progress = True
try:
context = await self._prepare_context(ids)
self._task_manager.create_task(
import_elements(ids, context),
"{} import".format(self._name),
handle_exceptions=False
)
except:
self._import_in_progress = False
raise
class Plugin: