Browse Source

Update factory for export repository

pull/1764/head
Hironsan 2 years ago
parent
commit
a361f17d84
2 changed files with 3 additions and 3 deletions
  1. 2
      backend/data_export/celery_tasks.py
  2. 4
      backend/data_export/pipeline/factories.py

2
backend/data_export/celery_tasks.py

@ -13,7 +13,7 @@ logger = get_task_logger(__name__)
@shared_task
def export_dataset(project_id, file_format: str, export_approved=False):
project = get_object_or_404(Project, pk=project_id)
repository = create_repository(project)
repository = create_repository(project, file_format)
writer = create_writer(file_format)(settings.MEDIA_ROOT)
service = ExportApplicationService(repository, writer)
filepath = service.export(export_approved)

4
backend/data_export/pipeline/factories.py

@ -11,8 +11,8 @@ from projects.models import (
)
def create_repository(project):
if getattr(project, "use_relation", False):
def create_repository(project, file_format: str):
if getattr(project, "use_relation", False) and file_format == catalog.JSONLRelation.name:
return repositories.RelationExtractionRepository(project)
mapping = {
DOCUMENT_CLASSIFICATION: repositories.TextClassificationRepository,

Loading…
Cancel
Save