Skip to content

Commit

Permalink
Fixed a regression bug.
Browse files Browse the repository at this point in the history
  • Loading branch information
janvanmansum committed Dec 11, 2024
1 parent 47e0469 commit 4b6ed87
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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());

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}
}

0 comments on commit 4b6ed87

Please sign in to comment.