Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/).

## [Unreleased]

### Fixed

- **Identity auto-population event listeners** (`add_inchi_identities_before_flush`, `add_smiles_extras_before_flush`, `add_hill_extras_before_flush`): Now correctly handle `StationaryPointRow` objects created with relationship objects (`geometry=geo_row`) in addition to foreign key IDs (`geometry_id=geom.id`). Previously, the listeners only checked `geometry_id` and used `session.get()` to load the geometry, which failed when objects were created with relationships and added together without intermediate flushes (as in batch workflow patterns). The fix tries the relationship first, then falls back to FK-based loading, supporting both creation patterns.

## [0.0.14] - 2026-09-01
### Changed
-- **Bump** `automol` to v0.0.23 to resolve dependency installations
Expand Down
53 changes: 33 additions & 20 deletions pixi.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

30 changes: 19 additions & 11 deletions src/autostorage/events.py
Original file line number Diff line number Diff line change
Expand Up @@ -228,11 +228,11 @@ def add_inchi_identities_before_flush(
if not isinstance(obj, StationaryPointRow):
continue

if obj.geometry_id is None or obj.identities:
continue

# Load the geometry
geometry_row = session.get(GeometryRow, obj.geometry_id)
# Get geometry - try relationship first (for `geometry=geo_row`),
# then load via FK (for `geometry_id=id`)
geometry_row = obj.geometry
if geometry_row is None and obj.geometry_id is not None:
geometry_row = session.get(GeometryRow, obj.geometry_id)
if geometry_row is None:
continue

Expand Down Expand Up @@ -298,11 +298,15 @@ def add_smiles_extras_before_flush(
if not isinstance(obj, StationaryPointRow):
continue

if obj.geometry_id is None or not obj.identities:
# Skip if no identities attached yet
if not obj.identities:
continue

# Load the geometry
geometry_row = session.get(GeometryRow, obj.geometry_id)
# Get geometry - try relationship first (for `geometry=geo_row`),
# then load via FK (for `geometry_id=id`)
geometry_row = obj.geometry
if geometry_row is None and obj.geometry_id is not None:
geometry_row = session.get(GeometryRow, obj.geometry_id)
if geometry_row is None:
continue

Expand Down Expand Up @@ -349,11 +353,15 @@ def add_hill_extras_before_flush(
if not isinstance(obj, StationaryPointRow):
continue

if obj.geometry_id is None or not obj.identities:
# Skip if no identities attached yet
if not obj.identities:
continue

# Load the geometry
geometry_row = session.get(GeometryRow, obj.geometry_id)
# Get geometry - try relationship first (for `geometry=geo_row`),
# then load via FK (for `geometry_id=id`)
geometry_row = obj.geometry
if geometry_row is None and obj.geometry_id is not None:
geometry_row = session.get(GeometryRow, obj.geometry_id)
if geometry_row is None:
continue

Expand Down
37 changes: 37 additions & 0 deletions tests/test_events.py
Original file line number Diff line number Diff line change
Expand Up @@ -1216,6 +1216,43 @@ def test_different_geometries_create_different_identities(
identity_count = session.query(IdentityRow).count()
assert identity_count == EXPECTED_IDENTITY_COUNT_TWO

def test_inchi_identity_added_with_relationship_object(
self, database: Database, make_model_opt: Callable[[], ModelRow]
) -> None:
"""InChI identity is added when StationaryPointRow uses relationship object."""
with database.session() as session:
model = make_model_opt()
session.add(model)
session.flush()

calc = CalculationRow(
calc_type="opt",
model_id=model.id,
input_provenance={},
output_provenance={},
)
geom = GeometryRow(
symbols=["C", "O"],
coordinates=[[0.0, 0.0, 0.0], [1.5, 0.0, 0.0]],
charge=0,
spin=1,
)

# Create StationaryPointRow with relationship objects (no IDs)
# This mimics the pattern used in the demo where objects are created
# and added together without intermediate flushes
stat_point = StationaryPointRow(calculation=calc, geometry=geom, order=0)

session.add_all([calc, geom, stat_point])
session.flush()

# Identity should be auto-populated despite using relationship objects
assert len(stat_point.identities) == 1
identity = stat_point.identities[0]
assert identity.kind == "stereoisomer"
assert identity.algorithm == "rdkit inchi"
assert identity.value.startswith("InChI=")


class TestAddSmilesExtras:
"""Tests for add_smiles_extras_before_flush event listener."""
Expand Down