diff options
| author | Thomas White <taw@physics.org> | 2022-03-28 14:57:05 +0200 |
|---|---|---|
| committer | Thomas White <taw@physics.org> | 2022-06-02 12:15:38 +0200 |
| commit | 2bf23b74fc94e95b15d93aff65505dcc8bf10176 (patch) | |
| tree | e824c3db7c565c8bdf7d407a73d35be3f0c2cca1 /src/im-asapo.c | |
| parent | be3595c63e5d310624f03be05cb2d2006c4963d2 (diff) | |
Add instance ID and pipeline step
Diffstat (limited to 'src/im-asapo.c')
| -rw-r--r-- | src/im-asapo.c | 17 |
1 files changed, 14 insertions, 3 deletions
diff --git a/src/im-asapo.c b/src/im-asapo.c index 388fe8da..68635946 100644 --- a/src/im-asapo.c +++ b/src/im-asapo.c @@ -69,7 +69,13 @@ char *im_asapo_make_unique_group_id(const char *endpoint, AsapoStringHandle group_id; AsapoErrorHandle err = asapo_new_handle(); - cred = asapo_create_source_credentials(kProcessed, "", "", "", token); + cred = asapo_create_source_credentials(kProcessed, + "", /* instance ID */ + "", /* pipeline step */ + "", /* beamtime */ + "", /* beamline */ + "", /* data source */ + token); consumer = asapo_create_consumer(endpoint, "", 0, cred, &err); asapo_free_handle(&cred); if ( asapo_is_error(err) ) { @@ -102,8 +108,13 @@ struct im_asapo *im_asapo_connect(const char *endpoint, a = malloc(sizeof(struct im_asapo)); if ( a == NULL ) return NULL; - cred = asapo_create_source_credentials(kProcessed, beamtime, "", - data_source, token); + cred = asapo_create_source_credentials(kProcessed, + "auto", /* instance ID */ + "indexamajig", /* pipeline step */ + beamtime, + "", /* beamline */ + data_source, + token); a->consumer = asapo_create_consumer(endpoint, "auto", 0, cred, &err); asapo_free_handle(&cred); if ( asapo_is_error(err) ) { |