diff --git a/pycarol/cds.py b/pycarol/cds.py index 36adee29..ebb9f8d7 100644 --- a/pycarol/cds.py +++ b/pycarol/cds.py @@ -41,7 +41,7 @@ def check_worker_type(worker_type): Warning, stacklevel=3 ) -@deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') +@deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') class CDSStaging: """ Class to handle all CDS Staging iterations. @@ -331,7 +331,7 @@ def count(self, staging_name, connector_id=None, connector_name=None): "stagingType": staging_name} return self.carol.call_api(path='v1/cds/staging/fetchCount', method='POST', params=query_params).get('count') -@deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') +@deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') class CDSGolden: """ Class to handle all CDS Staging iterations. diff --git a/pycarol/data_models/data_models.py b/pycarol/data_models/data_models.py index b0d6dee0..26751d60 100644 --- a/pycarol/data_models/data_models.py +++ b/pycarol/data_models/data_models.py @@ -102,7 +102,7 @@ def _get(self, id, by='id'): {resp['mdmName']: self._get_name_type_data_models(resp['mdmFields'])}) return resp - @deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') + @deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') def fetch_parquet( self, dm_name, merge_records=True, backend='pandas', return_dask_graph=False, diff --git a/pycarol/functions/misc.py b/pycarol/functions/misc.py index fc9bf9ab..e83dce06 100644 --- a/pycarol/functions/misc.py +++ b/pycarol/functions/misc.py @@ -77,7 +77,7 @@ def callback(task_list): if callable(callback): callback(task_status) -@deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') +@deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') def delele_all_golden_data(carol, dm_name): """Delete golden files from a datamodel in all storages. @@ -118,7 +118,7 @@ def par_delete_golden(carol, dm_list, n_jobs=5): for i in dm_list) return list(chain(*tasks)) -@deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') +@deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') def delete_staging_data(carol, staging_name, connector_name): """Delete a staging. diff --git a/pycarol/staging.py b/pycarol/staging.py index e293c7ee..9b64d637 100644 --- a/pycarol/staging.py +++ b/pycarol/staging.py @@ -399,7 +399,7 @@ def _connector_by_name(self, connector_name): """ return Connectors(self.carol).get_by_name(connector_name)['mdmId'] - @deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') + @deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') def fetch_parquet(self, staging_name, connector_id=None, connector_name=None, backend='pandas', merge_records=True, return_dask_graph=False, columns=None, max_hits=None, return_metadata=False, callback=None, cds=True, max_workers=None, file_pattern=None, diff --git a/pycarol/utils/miscellaneous.py b/pycarol/utils/miscellaneous.py index cf566a47..91c0ccc6 100644 --- a/pycarol/utils/miscellaneous.py +++ b/pycarol/utils/miscellaneous.py @@ -6,7 +6,7 @@ from pycarol.utils.deprecation_msgs import deprecated _FILE_MARKER = '' -@deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') +@deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') def drop_duplicated_parquet_dask(d, untie_field='mdmCounterForEntity'): """ Merge updates and delete records from the parquet files in CDS. @@ -35,7 +35,7 @@ def drop_duplicated_parquet_dask(d, untie_field='mdmCounterForEntity'): d = d.reset_index(drop=True) return d -@deprecated('2.55.1', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') +@deprecated('2.55.2', '2.56.0', 'CDS Data reading is deprecated - Use Big Query layer to read data from Carol.') def drop_duplicated_parquet(d, untie_field='mdmCounterForEntity'): """ Merge updates and delete records from the parquet files in CDS.