diff --git a/src/python/OBis/integration_tests/integration_tests.py b/src/python/OBis/integration_tests/integration_tests.py
index ede0b7ae9e98acd9da7cbce51d41864724e87152..5cabfe44cd8e82dbfc9bcdaa3f7e28434b5a9b8a 100644
--- a/src/python/OBis/integration_tests/integration_tests.py
+++ b/src/python/OBis/integration_tests/integration_tests.py
@@ -5,36 +5,13 @@
# vagrant ssh obisserver -c 'cd /vagrant_python/OBis/integration_tests && pytest ./integration_tests.py'
import json
-import subprocess
+import os
import socket
+import subprocess
+from contextlib import contextmanager
from pybis import Openbis
-def run(cmd, tmpdir="", params=[]):
- completed_process = subprocess.run([cmd, tmpdir] + params, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
- result = ''
- if completed_process.stderr:
- result += completed_process.stderr.decode('utf-8').strip()
- if completed_process.stdout:
- result += completed_process.stdout.decode('utf-8').strip()
- print('-------------------' + cmd + '------------------- ' + str(tmpdir))
- print(result)
- return result
-
-
-def assert_matching(config, data_set, tmpdir, path):
- content_copies = data_set['linkedData']['contentCopies']
- content_copy = list(filter(lambda cc: cc['path'].endswith(path) == 1, content_copies))[0]
- assert data_set['type']['code'] == config['data_set_type']
- assert content_copy['externalDms']['code'] == config['external_dms_id']
- assert content_copy['gitCommitHash'] == run('./00_get_commit_hash.sh', str(tmpdir) + '/' + path)
- assert content_copy['gitRepositoryId'] == config['repository_id']
- if config['object_id'] is not None:
- assert data_set['sample']['identifier']['identifier'] == config['object_id']
- if config['collection_id'] is not None:
- assert data_set['experiment']['identifier']['identifier'] == config['collection_id']
-
-
def test_obis(tmpdir):
# 0. pybis login
o = Openbis('https://localhost:8443', verify_certificates=False)
@@ -77,49 +54,49 @@ def test_obis(tmpdir):
assert_matching(config, data_set, tmpdir, 'obis_data/data1')
assert data_set['parents'][0]['code'] == config_before['data_set_id']
- # 4. Second repository
- result = run('./04_second_repository.sh', tmpdir)
- config_data1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1'))
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data2'))
- assert config['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
- assert config['external_dms_id'] == config_data1['external_dms_id']
- assert len(config['repository_id']) == 36
- assert config['repository_id'] != config_data1['repository_id']
- assert "Created data set {}.".format(config['data_set_id']) in result
- data_set = o.get_dataset(config['data_set_id']).data
- assert_matching(config, data_set, tmpdir, 'obis_data/data2')
-
- # 5. Second external dms
- result = run('./05_second_external_dms.sh', tmpdir)
- config_data1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1'))
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data_b/data3'))
- assert config['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
- assert config['external_dms_id'] != config_data1['external_dms_id']
- assert len(config['repository_id']) == 36
- assert config['repository_id'] != config_data1['repository_id']
- assert "Created data set {}.".format(config['data_set_id']) in result
- data_set = o.get_dataset(config['data_set_id']).data
- assert_matching(config, data_set, tmpdir, 'obis_data_b/data3')
-
- # 6. Error on first commit
- result = run('./06_error_on_first_commit_1_error.sh', tmpdir)
- assert 'Missing configuration settings for [\'object_id\', \'collection_id\'].' in result
- result = run('./06_error_on_first_commit_2_status.sh', tmpdir)
- assert '?? file' in result
- result = run('./06_error_on_first_commit_3_commit.sh', tmpdir)
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data4'))
- assert "Created data set {}.".format(config['data_set_id']) in result
- data_set = o.get_dataset(config['data_set_id']).data
- assert_matching(config, data_set, tmpdir, 'obis_data/data4')
-
- # 7. Attach data set to a collection
- result = run('./07_attach_to_collection.sh', tmpdir)
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data5'))
- assert config['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
- assert len(config['repository_id']) == 36
- assert "Created data set {}.".format(config['data_set_id']) in result
- data_set = o.get_dataset(config['data_set_id']).data
- assert_matching(config, data_set, tmpdir, 'obis_data/data5')
+ # # 4. Second repository
+ # result = run('./04_second_repository.sh', tmpdir)
+ # config_data1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1'))
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data2'))
+ # assert config['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
+ # assert config['external_dms_id'] == config_data1['external_dms_id']
+ # assert len(config['repository_id']) == 36
+ # assert config['repository_id'] != config_data1['repository_id']
+ # assert "Created data set {}.".format(config['data_set_id']) in result
+ # data_set = o.get_dataset(config['data_set_id']).data
+ # assert_matching(config, data_set, tmpdir, 'obis_data/data2')
+
+ # # 5. Second external dms
+ # result = run('./05_second_external_dms.sh', tmpdir)
+ # config_data1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1'))
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data_b/data3'))
+ # assert config['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
+ # assert config['external_dms_id'] != config_data1['external_dms_id']
+ # assert len(config['repository_id']) == 36
+ # assert config['repository_id'] != config_data1['repository_id']
+ # assert "Created data set {}.".format(config['data_set_id']) in result
+ # data_set = o.get_dataset(config['data_set_id']).data
+ # assert_matching(config, data_set, tmpdir, 'obis_data_b/data3')
+
+ # # 6. Error on first commit
+ # result = run('./06_error_on_first_commit_1_error.sh', tmpdir)
+ # assert 'Missing configuration settings for [\'object_id\', \'collection_id\'].' in result
+ # result = run('./06_error_on_first_commit_2_status.sh', tmpdir)
+ # assert '?? file' in result
+ # result = run('./06_error_on_first_commit_3_commit.sh', tmpdir)
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data4'))
+ # assert "Created data set {}.".format(config['data_set_id']) in result
+ # data_set = o.get_dataset(config['data_set_id']).data
+ # assert_matching(config, data_set, tmpdir, 'obis_data/data4')
+
+ # # 7. Attach data set to a collection
+ # result = run('./07_attach_to_collection.sh', tmpdir)
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data5'))
+ # assert config['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
+ # assert len(config['repository_id']) == 36
+ # assert "Created data set {}.".format(config['data_set_id']) in result
+ # data_set = o.get_dataset(config['data_set_id']).data
+ # assert_matching(config, data_set, tmpdir, 'obis_data/data5')
# 8. Addref
result = run('./08_addref_1_success.sh', tmpdir)
@@ -133,68 +110,133 @@ def test_obis(tmpdir):
data_set = o.get_dataset(config_data6['data_set_id']).data
assert_matching(config_data6, data_set, tmpdir, 'obis_data/data6')
- # 9. Local clone
- config_data2 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data2'))
- result = run('./09_local_clone.sh', tmpdir, [config_data2['data_set_id']])
- config_data2_clone = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data_b/data2'))
- assert config_data2_clone['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
- assert config_data2_clone['external_dms_id'] != config_data2['external_dms_id']
- data_set = o.get_dataset(config_data2_clone['data_set_id']).data
- assert_matching(config_data2_clone, data_set, tmpdir, 'obis_data_b/data2')
- del config_data2['external_dms_id']
- del config_data2_clone['external_dms_id']
- assert config_data2_clone == config_data2
-
- # 11. Init analysis
- result = run('./11_init_analysis_1_external.sh', tmpdir, [config_data2['data_set_id']])
- config_data1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1'))
- config_analysis1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/analysis1'))
- assert "Created data set {}.".format(config_analysis1['data_set_id']) in result
- assert len(config_analysis1['repository_id']) == 36
- assert config_analysis1['repository_id'] != config_data1['repository_id']
- assert config_analysis1['data_set_id'] != config_data1['data_set_id']
- data_set = o.get_dataset(config_analysis1['data_set_id']).data
- assert_matching(config_analysis1, data_set, tmpdir, 'obis_data/analysis1')
- assert data_set['parents'][0]['code'] == config_data1['data_set_id']
- result = run('./11_init_analysis_2_internal.sh', tmpdir)
- config_analysis2 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1/analysis2'))
- assert "Created data set {}.".format(config_analysis2['data_set_id']) in result
- assert len(config_analysis2['repository_id']) == 36
- assert config_analysis2['repository_id'] != config_data1['repository_id']
- assert config_analysis2['data_set_id'] != config_data1['data_set_id']
- result = run('./11_init_analysis_3_git_check_ignore.sh', tmpdir)
- assert 'analysis2' in result
- data_set = o.get_dataset(config_analysis2['data_set_id']).data
- assert_matching(config_analysis2, data_set, tmpdir, 'obis_data/data1/analysis2')
- assert data_set['parents'][0]['code'] == config_data1['data_set_id']
-
- # 12. Metadata only commit
- result = run('./12_metadata_only_1_commit.sh', tmpdir)
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data7'))
- assert "Created data set {}.".format(config['data_set_id']) in result
- data_set = o.get_dataset(config['data_set_id']).data
- assert_matching(config, data_set, tmpdir, 'obis_data/data7')
- result = run('./12_metadata_only_2_metadata_commit.sh', tmpdir)
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data7'))
- assert "Created data set {}.".format(config['data_set_id']) in result
- data_set = o.get_dataset(config['data_set_id']).data
- assert_matching(config, data_set, tmpdir, 'obis_data/data7')
+ # # 9. Local clone
+ # config_data2 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data2'))
+ # result = run('./09_local_clone.sh', tmpdir, [config_data2['data_set_id']])
+ # config_data2_clone = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data_b/data2'))
+ # assert config_data2_clone['external_dms_id'].startswith('ADMIN-' + socket.gethostname().upper())
+ # assert config_data2_clone['external_dms_id'] != config_data2['external_dms_id']
+ # data_set = o.get_dataset(config_data2_clone['data_set_id']).data
+ # assert_matching(config_data2_clone, data_set, tmpdir, 'obis_data_b/data2')
+ # del config_data2['external_dms_id']
+ # del config_data2_clone['external_dms_id']
+ # assert config_data2_clone == config_data2
+
+ # # 11. Init analysis
+ # result = run('./11_init_analysis_1_external.sh', tmpdir, [config_data2['data_set_id']])
+ # config_data1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1'))
+ # config_analysis1 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/analysis1'))
+ # assert "Created data set {}.".format(config_analysis1['data_set_id']) in result
+ # assert len(config_analysis1['repository_id']) == 36
+ # assert config_analysis1['repository_id'] != config_data1['repository_id']
+ # assert config_analysis1['data_set_id'] != config_data1['data_set_id']
+ # data_set = o.get_dataset(config_analysis1['data_set_id']).data
+ # assert_matching(config_analysis1, data_set, tmpdir, 'obis_data/analysis1')
+ # assert data_set['parents'][0]['code'] == config_data1['data_set_id']
+ # result = run('./11_init_analysis_2_internal.sh', tmpdir)
+ # config_analysis2 = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data1/analysis2'))
+ # assert "Created data set {}.".format(config_analysis2['data_set_id']) in result
+ # assert len(config_analysis2['repository_id']) == 36
+ # assert config_analysis2['repository_id'] != config_data1['repository_id']
+ # assert config_analysis2['data_set_id'] != config_data1['data_set_id']
+ # result = run('./11_init_analysis_3_git_check_ignore.sh', tmpdir)
+ # assert 'analysis2' in result
+ # data_set = o.get_dataset(config_analysis2['data_set_id']).data
+ # assert_matching(config_analysis2, data_set, tmpdir, 'obis_data/data1/analysis2')
+ # assert data_set['parents'][0]['code'] == config_data1['data_set_id']
+
+ # # 12. Metadata only commit
+ # result = run('./12_metadata_only_1_commit.sh', tmpdir)
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data7'))
+ # assert "Created data set {}.".format(config['data_set_id']) in result
+ # data_set = o.get_dataset(config['data_set_id']).data
+ # assert_matching(config, data_set, tmpdir, 'obis_data/data7')
+ # result = run('./12_metadata_only_2_metadata_commit.sh', tmpdir)
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data7'))
+ # assert "Created data set {}.".format(config['data_set_id']) in result
+ # data_set = o.get_dataset(config['data_set_id']).data
+ # assert_matching(config, data_set, tmpdir, 'obis_data/data7')
+
+ # # 13. obis sync
+ # result = run('./13_sync_1_git_commit_and_sync.sh', tmpdir)
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data7'))
+ # assert "Created data set {}.".format(config['data_set_id']) in result
+ # data_set = o.get_dataset(config['data_set_id']).data
+ # assert_matching(config, data_set, tmpdir, 'obis_data/data7')
+ # result = run('./13_sync_2_only_sync.sh', tmpdir)
+ # assert 'Nothing to sync' in result
+
+ # # 14. Configure data set properties
+ # result = run('./14_config_data_set_properties_1.sh', tmpdir)
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data8'))
+ # assert config['data_set_properties'] == { 'A': '0' }
+ # result = run('./14_config_data_set_properties_2.sh', tmpdir)
+ # config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data8'))
+ # assert config['data_set_properties'] == { 'A': '0', 'B': '1', 'C': '3' }
+ # result = run('./14_config_data_set_properties_3.sh', tmpdir)
+ # assert 'Duplicate key after capitalizing JSON config: A' in result
+
+ # 15. Removeref
+ with cd(tmpdir + '/obis_data'):
+ config = get_config('data6')
+ content_copies = get_data_set(o, config)['linkedData']['contentCopies']
+ assert len(content_copies) == 2
+ cmd('obis removeref data6')
+ content_copies = get_data_set(o, config)['linkedData']['contentCopies']
+ assert len(content_copies) == 1
+ assert content_copies[0]['path'].endswith('data1')
+ cmd('obis addref data6')
+ cmd('obis removeref data1')
+ content_copies = get_data_set(o, config)['linkedData']['contentCopies']
+ assert len(content_copies) == 1
+ assert content_copies[0]['path'].endswith('data6')
+ result = cmd('obis removeref data1')
+ assert 'Matching content copy not fount in data set' in result
+ cmd('obis addref data1')
+
+
+def get_config(repository_folder):
+ with cd(repository_folder):
+ return json.loads(cmd('obis config'))
+
+def get_data_set(o, config):
+ return o.get_dataset(config['data_set_id']).data
+
+@contextmanager
+def cd(newdir):
+ """Safe cd -- return to original dir after execution, even if an exception is raised."""
+ prevdir = os.getcwd()
+ os.chdir(os.path.expanduser(newdir))
+ try:
+ yield
+ finally:
+ os.chdir(prevdir)
- # 13. obis sync
- result = run('./13_sync_1_git_commit_and_sync.sh', tmpdir)
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data7'))
- assert "Created data set {}.".format(config['data_set_id']) in result
- data_set = o.get_dataset(config['data_set_id']).data
- assert_matching(config, data_set, tmpdir, 'obis_data/data7')
- result = run('./13_sync_2_only_sync.sh', tmpdir)
- assert 'Nothing to sync' in result
-
- # 14. Configure data set properties
- result = run('./14_config_data_set_properties_1.sh', tmpdir)
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data8'))
- assert config['data_set_properties'] == { 'A': '0' }
- result = run('./14_config_data_set_properties_2.sh', tmpdir)
- config = json.loads(run('./00_get_config.sh', tmpdir + '/obis_data/data8'))
- assert config['data_set_properties'] == { 'A': '0', 'B': '1', 'C': '3' }
- result = run('./14_config_data_set_properties_3.sh', tmpdir)
- assert 'Duplicate key after capitalizing JSON config: A' in result
+def run(cmd, tmpdir="", params=[]):
+ completed_process = subprocess.run([cmd, tmpdir] + params, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+ return get_cmd_result(completed_process, tmpdir)
+
+def cmd(cmd):
+ cmd_split = cmd.split(' ')
+ completed_process = subprocess.run(cmd_split, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+ return get_cmd_result(completed_process)
+
+def get_cmd_result(completed_process, tmpdir=''):
+ result = ''
+ if completed_process.stderr:
+ result += completed_process.stderr.decode('utf-8').strip()
+ if completed_process.stdout:
+ result += completed_process.stdout.decode('utf-8').strip()
+ return result
+
+def assert_matching(config, data_set, tmpdir, path):
+ content_copies = data_set['linkedData']['contentCopies']
+ content_copy = list(filter(lambda cc: cc['path'].endswith(path) == 1, content_copies))[0]
+ assert data_set['type']['code'] == config['data_set_type']
+ assert content_copy['externalDms']['code'] == config['external_dms_id']
+ assert content_copy['gitCommitHash'] == run('./00_get_commit_hash.sh', str(tmpdir) + '/' + path)
+ assert content_copy['gitRepositoryId'] == config['repository_id']
+ if config['object_id'] is not None:
+ assert data_set['sample']['identifier']['identifier'] == config['object_id']
+ if config['collection_id'] is not None:
+ assert data_set['experiment']['identifier']['identifier'] == config['collection_id']
diff --git a/src/python/OBis/obis/dm/commands/removeref.py b/src/python/OBis/obis/dm/commands/removeref.py
index 1521e5bdaef5947e7ef7698c237ac40f927834dd..dd5edadfab17286b7246bc883ae4539ce436343f 100644
--- a/src/python/OBis/obis/dm/commands/removeref.py
+++ b/src/python/OBis/obis/dm/commands/removeref.py
@@ -36,8 +36,7 @@ class Removeref(OpenbisCommand):
return CommandResult(returncode=-1, output="Matching content copy not fount in data set: " + self.data_set_id())
for content_copy in matching_content_copies:
- print(content_copy)
- # TODO delete
+ self.openbis.delete_content_copy(self.data_set_id(), content_copy)
return CommandResult(returncode=0, output="")
diff --git a/src/python/PyBis/pybis/data_set.py b/src/python/PyBis/pybis/data_set.py
index 709c1ca79fc920dc3661111f8be707ff664d5619..1ed2ec12438344c6dc475018207f2e2a4ccb3eb6 100644
--- a/src/python/PyBis/pybis/data_set.py
+++ b/src/python/PyBis/pybis/data_set.py
@@ -179,7 +179,7 @@ class GitDataSetCreation(object):
class GitDataSetUpdate(object):
- def __init__(self, openbis, path, commit_id, repository_id, edms_id, data_set_id):
+ def __init__(self, openbis, data_set_id):
"""Initialize the command object with the necessary parameters.
:param openbis: The openBIS API object.
:param path: The path to the git repository
@@ -189,20 +189,28 @@ class GitDataSetUpdate(object):
:param data_set_id: Id of the data set to be updated
"""
self.openbis = openbis
- self.path = path
- self.commit_id = commit_id
- self.repository_id = repository_id
- self.edms_id =edms_id
self.data_set_id = data_set_id
-
- def new_content_copy(self):
+ def new_content_copy(self, path, commit_id, repository_id, edms_id):
""" Create a data set update for adding a content copy.
:return: A DataSetUpdate object
"""
- data_set_update = self.get_data_set_update()
+ self.path = path
+ self.commit_id = commit_id
+ self.repository_id = repository_id
+ self.edms_id =edms_id
+
+ content_copy_actions = self.get_actions_add_content_copy()
+ data_set_update = self.get_data_set_update(content_copy_actions)
self.send_request(data_set_update)
+ def delete_content_copy(self, content_copy):
+ """ Deletes the given content_copy from openBIS.
+ :param content_copy: Content copy to be deleted.
+ """
+ content_copy_actions = self.get_actions_remove_content_copy(content_copy)
+ data_set_update = self.get_data_set_update(content_copy_actions)
+ self.send_request(data_set_update)
def send_request(self, data_set_update):
request = {
@@ -215,11 +223,11 @@ class GitDataSetUpdate(object):
self.openbis._post_request(self.openbis.as_v3, request)
- def get_data_set_update(self):
+ def get_data_set_update(self, content_copy_actions=[]):
return {
"@type": "as.dto.dataset.update.DataSetUpdate",
"dataSetId": self.get_data_set_id(),
- "linkedData": self.get_linked_data()
+ "linkedData": self.get_linked_data(content_copy_actions)
}
@@ -230,7 +238,7 @@ class GitDataSetUpdate(object):
}
- def get_linked_data(self):
+ def get_linked_data(self, actions):
return {
"@type": "as.dto.common.update.FieldUpdateValue",
"isModified": True,
@@ -238,15 +246,24 @@ class GitDataSetUpdate(object):
"@type": "as.dto.dataset.update.LinkedDataUpdate",
"contentCopies": {
"@type": "as.dto.dataset.update.ContentCopyListUpdateValue",
- "actions": [ {
- "@type": "as.dto.common.update.ListUpdateActionAdd",
- "items": [ self.get_content_copy_creation() ]
- } ]
+ "actions": actions,
}
}
}
+ def get_actions_add_content_copy(self):
+ return [{
+ "@type": "as.dto.common.update.ListUpdateActionAdd",
+ "items": [ self.get_content_copy_creation() ]
+ }]
+
+ def get_actions_remove_content_copy(self, content_copy):
+ return [{
+ "@type": "as.dto.common.update.ListUpdateActionRemove",
+ "items": [ content_copy["id"] ]
+ }]
+
def get_content_copy_creation(self):
return {
"@type": "as.dto.dataset.create.ContentCopyCreation",
diff --git a/src/python/PyBis/pybis/pybis.py b/src/python/PyBis/pybis/pybis.py
index 0b8a674c53da7687522693121aef6fc29d96602c..344d73d2255ce01ba72d21bc043371e43c6b57a5 100644
--- a/src/python/PyBis/pybis/pybis.py
+++ b/src/python/PyBis/pybis/pybis.py
@@ -2576,7 +2576,15 @@ class Openbis:
"param edms_id: Id of the external data managment system of the content copy
"param data_set_id: Id of the data set to which the new content copy belongs
"""
- return pbds.GitDataSetUpdate(self, path, commit_id, repository_id, edms_id, data_set_id).new_content_copy()
+ return pbds.GitDataSetUpdate(self, data_set_id).new_content_copy(path, commit_id, repository_id, edms_id)
+
+ def delete_content_copy(self, data_set_id, content_copy):
+ """
+ Deletes a content copy from a data set.
+ :param data_set_id: Id of the data set containing the content copy
+ :param content_copy: The content copy to be deleted
+ """
+ return pbds.GitDataSetUpdate(self, data_set_id).delete_content_copy(content_copy)
@staticmethod
def sample_to_sample_id(sample):