diff --git a/docs/site/examples/frozen_versions/21.06.0/getting_started/python/produce.py b/docs/site/examples/frozen_versions/21.06.0/getting_started/python/produce.py
index e8e9efd86dc089c6e023f201e3ac19501a20e5a4..063ec05fa1ee1e8403d3cd8793e12e425ce1a570 100644
--- a/docs/site/examples/frozen_versions/21.06.0/getting_started/python/produce.py
+++ b/docs/site/examples/frozen_versions/21.06.0/getting_started/python/produce.py
@@ -10,7 +10,7 @@ endpoint = "localhost:8400"
 beamtime = "asapo_test"
 
 # source type 'processed' to write to the core filesystem
-producer = asapo_producer.create_producer(endpoint,'processed',
+producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',
                                           beamtime,'auto','test_source','', 1,60000)
 
 # we are sending a message with with index 1 to the default stream. Filename must start with processed/
diff --git a/docs/site/examples/getting_started/python/produce.py b/docs/site/examples/getting_started/python/produce.py
index e8e9efd86dc089c6e023f201e3ac19501a20e5a4..063ec05fa1ee1e8403d3cd8793e12e425ce1a570 100644
--- a/docs/site/examples/getting_started/python/produce.py
+++ b/docs/site/examples/getting_started/python/produce.py
@@ -10,7 +10,7 @@ endpoint = "localhost:8400"
 beamtime = "asapo_test"
 
 # source type 'processed' to write to the core filesystem
-producer = asapo_producer.create_producer(endpoint,'processed',
+producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',
                                           beamtime,'auto','test_source','', 1,60000)
 
 # we are sending a message with with index 1 to the default stream. Filename must start with processed/
diff --git a/tests/automatic/bug_fixes/error-sending-data-using-callback-method/bugfix_callback.py b/tests/automatic/bug_fixes/error-sending-data-using-callback-method/bugfix_callback.py
index 485410e11255acf83f84bb082ace4a60b9f72ba7..dff37d791b64a1bec9efdff8fb741891724d3b2a 100644
--- a/tests/automatic/bug_fixes/error-sending-data-using-callback-method/bugfix_callback.py
+++ b/tests/automatic/bug_fixes/error-sending-data-using-callback-method/bugfix_callback.py
@@ -25,7 +25,7 @@ class AsapoSender:
     def _callback(self, header, err):
     	print ("hello self callback")
 
-producer  = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads, 600000)
+producer  = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads, 600000)
 producer.set_log_level("debug")
 
 print(asapo_producer.__version__)
diff --git a/tests/automatic/producer/aai/producer_aai.py b/tests/automatic/producer/aai/producer_aai.py
index da575d7c727b2f6dee4dfd21c50a7c41cb755794..9d350bee41db6e14340bcc40713f478afa1739b5 100644
--- a/tests/automatic/producer/aai/producer_aai.py
+++ b/tests/automatic/producer/aai/producer_aai.py
@@ -27,7 +27,7 @@ def callback(header,err):
     lock.release()
 
 
-producer  = asapo_producer.create_producer(endpoint,'processed','auto',beamline, data_source, token, nthreads, 60000)
+producer  = asapo_producer.create_producer(endpoint,'auto','auto','processed','auto',beamline, data_source, token, nthreads, 60000)
 
 producer.set_log_level("debug")
 
diff --git a/tests/automatic/producer/python_api/producer_api.py b/tests/automatic/producer/python_api/producer_api.py
index beb45a12dd9d5544496655a28f9ca709a017ba14..3208d64bf8c38bc9ac4b8fd20b5aa29c638900de 100644
--- a/tests/automatic/producer/python_api/producer_api.py
+++ b/tests/automatic/producer/python_api/producer_api.py
@@ -47,7 +47,7 @@ def assert_version(version):
     if not ok:
         sys.exit(1)
 
-producer = asapo_producer.create_producer(endpoint,'processed', beamtime, 'auto', data_source, token, nthreads, 60000)
+producer = asapo_producer.create_producer(endpoint,'auto','auto','processed', beamtime, 'auto', data_source, token, nthreads, 60000)
 
 producer.set_log_level("debug")
 
@@ -233,7 +233,7 @@ else:
 
 # create with error
 try:
-    producer = asapo_producer.create_producer(endpoint,'processed', beamtime, 'auto', data_source, token, 0, 0)
+    producer = asapo_producer.create_producer(endpoint,'auto','auto','processed', beamtime, 'auto', data_source, token, 0, 0)
 except asapo_producer.AsapoWrongInputError as e:
     print(e)
 else:
diff --git a/tests/manual/python_tests/producer/short_test.py b/tests/manual/python_tests/producer/short_test.py
index eaf47f8286862472a2313f307cd0abc9f01455e3..983225d6256ef9ee80106e18443397f09c691585 100644
--- a/tests/manual/python_tests/producer/short_test.py
+++ b/tests/manual/python_tests/producer/short_test.py
@@ -26,7 +26,7 @@ def assert_err(err):
         print(err)
         sys.exit(1)
 
-producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads ,0)
+producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads ,0)
 
 producer.set_log_level("debug")
 
diff --git a/tests/manual/python_tests/producer/test.py b/tests/manual/python_tests/producer/test.py
index 403dc1d4623bba660f17f94a428b274f5770cec5..1bb1c5dd887858d7d661e7e80fbb2c16db05ddf1 100644
--- a/tests/manual/python_tests/producer/test.py
+++ b/tests/manual/python_tests/producer/test.py
@@ -27,7 +27,7 @@ def assert_err(err):
         print(err)
         sys.exit(1)
 
-producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads ,0)
+producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads ,0)
 
 producer.set_log_level("info")
 
diff --git a/tests/manual/python_tests/producer_wait_bug_mongo/test.py b/tests/manual/python_tests/producer_wait_bug_mongo/test.py
index ead637fdfcfac7c07b70a9ff243e83861ac3933b..b622a4e8d4050058502848ea8c896a48f0a9f00d 100644
--- a/tests/manual/python_tests/producer_wait_bug_mongo/test.py
+++ b/tests/manual/python_tests/producer_wait_bug_mongo/test.py
@@ -27,7 +27,7 @@ def assert_err(err):
         print(err)
         sys.exit(1)
 
-producer = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads, 600000)
+producer = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads, 600000)
 
 producer.set_log_level("debug")
 
diff --git a/tests/manual/python_tests/producer_wait_threads/producer_api.py b/tests/manual/python_tests/producer_wait_threads/producer_api.py
index 1c19ec7f15d22b82a85a185c6b6c32e1060bdf89..2f0acbd52e4d91c825514d56ebfc19bcdf6df792 100644
--- a/tests/manual/python_tests/producer_wait_threads/producer_api.py
+++ b/tests/manual/python_tests/producer_wait_threads/producer_api.py
@@ -22,7 +22,7 @@ def callback(header,err):
         print ("successfuly sent: ",header)
     lock.release()
 
-producer  = asapo_producer.create_producer(endpoint,'processed',beamtime, 'auto', data_source, token, nthreads, 600000)
+producer  = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime, 'auto', data_source, token, nthreads, 600000)
 
 producer.set_log_level("info")
 
@@ -63,7 +63,7 @@ if n!=0:
 
 # create with error
 try:
-    producer  = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, 0, 600000)
+    producer  = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, 0, 600000)
 except Exception as Asapo:
     print(e)
 else:
diff --git a/tests/manual/python_tests/producer_wait_threads/test.py b/tests/manual/python_tests/producer_wait_threads/test.py
index 75983e6b30571a4bec77ea1243d923606a4c1ae1..bd802d3857e7a570b7b22c024936e9f16d0bb76e 100644
--- a/tests/manual/python_tests/producer_wait_threads/test.py
+++ b/tests/manual/python_tests/producer_wait_threads/test.py
@@ -22,7 +22,7 @@ def callback(header,err):
         print ("successfuly sent: ",header)
     lock.release()
 
-producer  = asapo_producer.create_producer(endpoint,'processed',beamtime,'auto', data_source, token, nthreads, 600000)
+producer  = asapo_producer.create_producer(endpoint,'auto','auto','processed',beamtime,'auto', data_source, token, nthreads, 600000)
 
 producer.set_log_level("info")