From 2bf23b74fc94e95b15d93aff65505dcc8bf10176 Mon Sep 17 00:00:00 2001 From: Thomas White Date: Mon, 28 Mar 2022 14:57:05 +0200 Subject: Add instance ID and pipeline step --- src/im-asapo.c | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) (limited to 'src/im-asapo.c') 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) ) { -- cgit v1.2.3