diff --git a/moonstreamapi/moonstreamapi/actions.py b/moonstreamapi/moonstreamapi/actions.py index f75715e0..a2d4ad43 100644 --- a/moonstreamapi/moonstreamapi/actions.py +++ b/moonstreamapi/moonstreamapi/actions.py @@ -611,39 +611,18 @@ def delete_seer_subscription( ) -> None: """ Delete seer subscription from db - If there are no more subscriptions for this address,abi_selector delete all abis """ - - ## Delete subscription from db - + ### TEMPORARY disable deleting abi jobs from db + ### TODO(ANDREY): fix this try: - db_session.query(AbiSubscriptions).filter( + db_session.query(AbiSubscriptions).filter( AbiSubscriptions.subscription_id == subscription_id ).delete(synchronize_session=False) db_session.commit() except Exception as e: - logger.error(f"Error delete subscription from db: {str(e)}") + logger.error(f"Error deleting subscription from db: {str(e)}") db_session.rollback() - - not_connected_abi_jobs = ( - db_session.query(AbiJobs) - .join(AbiSubscriptions, AbiJobs.id == AbiSubscriptions.abi_job_id, isouter=True) - .filter(AbiSubscriptions.subscription_id == None) - .cte("not_connected_abi_jobs") - ) - - ## Delete abi jobs from db - - try: - db_session.query(AbiJobs).filter( - AbiJobs.id.in_(db_session.query(not_connected_abi_jobs.c.id)) - ).delete(synchronize_session=False) - - db_session.commit() - except Exception as e: - logger.error(f"Error delete abi jobs from db: {str(e)}") - db_session.rollback() - + return def add_abi_to_db( db_session: Session, diff --git a/moonstreamapi/moonstreamapi/version.py b/moonstreamapi/moonstreamapi/version.py index 932ff953..f4edd8a4 100644 --- a/moonstreamapi/moonstreamapi/version.py +++ b/moonstreamapi/moonstreamapi/version.py @@ -2,4 +2,4 @@ Moonstream library and API version. """ -MOONSTREAMAPI_VERSION = "0.4.11" +MOONSTREAMAPI_VERSION = "0.4.12"