Skip to content

Commit 83240a6

Browse files
committed
session connection issue in the sqlalchemy read queries
1 parent eb2a996 commit 83240a6

File tree

3 files changed

+8
-0
lines changed

3 files changed

+8
-0
lines changed

metering/repository/org_service_config_repository.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,4 +17,6 @@ def get_service_config(self, org_id, service_id, optin_time):
1717
.filter(OrgServiceConfigModel.org_id == org_id) \
1818
.filter(OrgServiceConfigModel.service_id == service_id)\
1919
.order_by(OrgServiceConfigModel.created_at.desc()).first()
20+
session.commit()
21+
session.flush()
2022
return service_config

metering/repository/usage_repository.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,15 @@ def get_total_calls(self, user_name, org_id, service_id):
1111
.filter(UserOrgGroupModel.user_name == user_name)\
1212
.filter(UserOrgGroupModel.org_id == org_id) \
1313
.filter(UserOrgGroupModel.service_id == service_id).all()
14+
session.commit()
15+
session.flush()
1416
return query_data[0].total_calls
1517

1618
def get_optin_time(self, user_name, org_id, service_id):
1719
session = self.get_default_session()
1820
query_data = session.query(func.min(UsageModel.created_at).label('opt_time')).join(UserOrgGroupModel).filter(
1921
UserOrgGroupModel.user_name == user_name).filter(UserOrgGroupModel.org_id == org_id).filter(
2022
UserOrgGroupModel.service_id == service_id).all()
23+
session.commit()
24+
session.flush()
2125
return query_data[0].opt_time

metering/repository/user_org_group_repository.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,8 @@ def get_user_org_group_data(self, payment_group_id, org_id, user_name, service_i
1616
UserOrgGroupModel.payment_group_id == payment_group_id)
1717

1818
user_org_group_data = user_org_query.first()
19+
session.commit()
20+
session.flush()
1921
return user_org_group_data
2022

2123
def get_free_calls(self, org_id, service_id, optin_time):

0 commit comments

Comments
 (0)