gCubeSystem
/
gFeed
15
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/trunk/data-publishing/gCat-Feeder-Suite@179776 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Fabio Sinibaldi 2019-06-11 12:13:19 +00:00
parent ef74ea159a
commit 8f60f5a0f3
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gCat-Feeder/src/main/java/org/gcube/data/publishing/gCatFeeder/service/engine/impl/ExecutionManagerImpl.java
View File

@ -7,6 +7,7 @@ import java.util.concurrent.TimeUnit;
import javax.annotation.PostConstruct;
import javax.inject.Inject;
import org.gcube.data.publishing.gCatFeeder.model.EnvironmentConfiguration;
import org.gcube.data.publishing.gCatFeeder.service.engine.CatalogueControllersManager;
import org.gcube.data.publishing.gCatFeeder.service.engine.CollectorsManager;
import org.gcube.data.publishing.gCatFeeder.service.engine.ExecutionManager;
@ -36,7 +37,8 @@ public class ExecutionManagerImpl implements ExecutionManager {
private Storage storage;
@Inject
private LocalConfiguration config;
@Inject
private EnvironmentConfiguration environmentConfig;
@PostConstruct
private void post() {
@ -79,6 +81,8 @@ public class ExecutionManagerImpl implements ExecutionManager {
toSubmit.setInfastructureInterface(infrastructure);
toSubmit.setPersistence(persistence);
toSubmit.setStorage(storage);
toSubmit.setEnvironmentConfiguration(environmentConfig);
if(!executor.getQueue().contains(toSubmit)) {
log.trace("Inserting execution in queue {} ");

3
gCat-Feeder/src/main/java/org/gcube/data/publishing/gCatFeeder/service/engine/impl/ExecutionTask.java
View File

@ -57,8 +57,7 @@ public class ExecutionTask implements Runnable {
public ExecutionTask(ExecutionDescriptor desc) {
super();
this.request=desc;
environmentConfiguration=new LiveEnvironmentConfiguration();
this.request=desc;
}