From 4b6ed8717fe90711acd2c04c9dfb66e33e55d3b1 Mon Sep 17 00:00:00 2001 From: Jan van Mansum Date: Wed, 11 Dec 2024 13:30:08 +0100 Subject: [PATCH] Fixed a regression bug. --- .../nl/knaw/dans/dvingest/DdDataverseIngestApplication.java | 2 +- src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java b/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java index 928702a..4e32127 100644 --- a/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java +++ b/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java @@ -118,7 +118,7 @@ public void run(final DdDataverseIngestConfiguration configuration, final Enviro * Auto ingest area */ var autoIngestConfig = configuration.getIngest().getAutoIngest(); - var inboxTaskFactory = new InboxTaskFactoryImpl(dataverseIngestDepositFactory, depositTaskFactoryImport); + var inboxTaskFactory = new InboxTaskFactoryImpl(dataverseIngestDepositFactory, depositTaskFactoryImport, autoIngestConfig.getOutbox()); var inbox = Inbox.builder().inbox(autoIngestConfig.getInbox()).taskFactory(inboxTaskFactory).build(); var autoIngestArea = new AutoIngestArea(inbox, autoIngestConfig.getOutbox()); diff --git a/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java b/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java index 924740c..8644f59 100644 --- a/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java +++ b/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java @@ -26,10 +26,11 @@ public class InboxTaskFactoryImpl implements InboxTaskFactory { private final DataverseIngestDepositFactory dataverseIngestDepositFactory; private final DepositTaskFactory depositTaskFactory; + private final Path outputDir; @Override public Runnable createInboxTask(Path path) { var dataVerseIngestDeposit = dataverseIngestDepositFactory.createDataverseIngestDeposit(path); - return depositTaskFactory.createDepositTask(dataVerseIngestDeposit, path, false); + return depositTaskFactory.createDepositTask(dataVerseIngestDeposit, outputDir, false); } }