Как использовать MarkLogic DataHub importFlow из другой базы данных

У меня есть пример использования, в котором необходимо запросить некоторые данные в одной базе данных, а затем использовать эти данные в качестве нового ввода в конвейер MarkLogic DataHub.

Я создал рабочий поток импорта и согласования.

Теперь я хочу запустить поток импорта из другой базы данных, чтобы вставить данные в промежуточную базу данных в dhf.

'use strict';

let id= "/ClueyTest/track/cluey/a2c5c32c-6e99-47c9-8b4d-5b97897509f7.json";

let options = {"dhf.projectName":"ClueyTest", "entity":"Track", "flow":"ImportClueyTracks", "flowType":"input", "dataFormat":"json"};

let rawContent = {
"trackId": "a2c5c32c-6e99-47c9-8b4d-5b97897509f7", 
"type": "Feature", 
"geometry": {
"type": "LineString", 
"coordinates": [
[5.4701967, 51.8190698], 
[5.470028, 51.8193624],
[5.470038, 51.8193624], 
[5.470048, 51.8193624], 
[5.470028, 51.8193634]]
}
, 
"properties": {
"timestamps": [
"2019-02-14T16:52:06+0100", 
"2019-02-14T16:51:07+0100", 
"2019-02-14T16:43:24+0100", 
"2019-02-14T16:43:24+0100", 
"2019-02-14T16:43:24+0100" 
]
}
, 
"tracktype": "on", 
"endTimestamp": "2019-02-14T16:51:07+0100", 
"startTimestamp": "2019-02-14T14:46:50+0100"
}

const clt = require('/entities/clueyTrack/input/ImportClueyTracks/main.sjs');

// the main in the import flow
clt.main(id,rawContent,options);

Очевидно, что для запуска этого кода вам понадобится рабочий поток импорта внутри концентратора данных, но вопрос заключается в общем варианте использования, как запускать поток импорта не из gradle, а из базы данных marklogic.

Весь код dhf - sjs.