diff --git a/toardb/data/crud.py b/toardb/data/crud.py index 6b878e237e0e774047b91bbac59851ffde424704..d3d3aab7f681c4410420cce2357a59b7bc99440b 100644 --- a/toardb/data/crud.py +++ b/toardb/data/crud.py @@ -309,42 +309,6 @@ def create_data_record(db: Session, engine: Engine, return JSONResponse(status_code=status_code, content=message) -def create_data_record_with_flag(db: Session, engine: Engine, - series_id: int, datetime: dt.datetime, - value: float, flag: str, version: str, - author_id: int): - flag_num = get_value_from_str(toardb.toardb.DF_vocabulary,flag) - data_dict = {"datetime": datetime, - "value": value, - "flags": flag_num, - "version": version, - "timeseries_id": series_id} - data = models.Data(**data_dict) - db.add(data) - result = db.commit() - db.refresh(data) - # create changelog entry - type_of_change = get_value_from_str(toardb.toardb.CL_vocabulary,"Created") - description="data record created" - db_changelog = TimeseriesChangelog(description=description, timeseries_id=series_id, author_id=author_id, type_of_change=type_of_change, - old_value='', new_value='', period_start=datetime, period_end=datetime, version=version) - db.add(db_changelog) - db.commit() - # adjust data_start_date, data_end_date - timeseries = get_timeseries(db=db,timeseries_id=series_id) - db.rollback() - datetime = datetime.replace(tzinfo=timeseries.data_end_date.tzinfo) - if datetime < timeseries.data_start_date: - timeseries.data_start_date = datetime - if datetime > timeseries.data_end_date: - timeseries.data_end_date = datetime - db.add(timeseries) - db.commit() - status_code=200 - message='Data successfully inserted.' - return JSONResponse(status_code=status_code, content=message) - - def insert_dataframe (db: Session, engine: Engine, df: pd.DataFrame, toarqc_config_type: str = 'standard', dry_run: bool = False, parameter: str = 'o3', preliminary: bool = False, force: bool = False): # df: pandas.DataFrame # index: datetime