|
|
@ -278,7 +278,7 @@ class YwsdForkRankMemberModel(ForkRankMemberModel):
|
|
|
|
conn.execute(
|
|
|
|
conn.execute(
|
|
|
|
ForkRank.member_table.update()
|
|
|
|
ForkRank.member_table.update()
|
|
|
|
.where(
|
|
|
|
.where(
|
|
|
|
_and(
|
|
|
|
sqlalchemy.and_(
|
|
|
|
ForkRank.member_table.c.forkrank_id
|
|
|
|
ForkRank.member_table.c.forkrank_id
|
|
|
|
== self.diffsync.get("forkrank", self.forkrank).forkrank_id,
|
|
|
|
== self.diffsync.get("forkrank", self.forkrank).forkrank_id,
|
|
|
|
ForkRank.member_table.c.extension_id
|
|
|
|
ForkRank.member_table.c.extension_id
|
|
|
@ -293,7 +293,7 @@ class YwsdForkRankMemberModel(ForkRankMemberModel):
|
|
|
|
with self.diffsync.engine.connect() as conn:
|
|
|
|
with self.diffsync.engine.connect() as conn:
|
|
|
|
conn.execute(
|
|
|
|
conn.execute(
|
|
|
|
ForkRank.member_table.delete().where(
|
|
|
|
ForkRank.member_table.delete().where(
|
|
|
|
_and(
|
|
|
|
sqlalchemy.and_(
|
|
|
|
ForkRank.member_table.c.forkrank_id
|
|
|
|
ForkRank.member_table.c.forkrank_id
|
|
|
|
== self.diffsync.get("forkrank", self.forkrank).forkrank_id,
|
|
|
|
== self.diffsync.get("forkrank", self.forkrank).forkrank_id,
|
|
|
|
ForkRank.member_table.c.extension_id
|
|
|
|
ForkRank.member_table.c.extension_id
|
|
|
|