Skip to content

Commit 04353aa

Browse files
committed
Change ReferenceProvider subscription id()
1 parent e7f63e9 commit 04353aa

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

ascetic_ddd/faker/domain/providers/reference_provider.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,7 @@ async def _observer(event: OutputPopulatedEvent[IdOutputT]):
229229
if not event.is_transient:
230230
await reference_provider.append(event.session, event.output)
231231

232-
self._aggregate_provider.id_provider.on_populated.attach(_observer, id(self._aggregate_provider))
232+
self._aggregate_provider.id_provider.on_populated.attach(_observer, id(reference_provider))
233233
self._subscribed = True
234234

235235
return self._aggregate_provider
@@ -273,7 +273,7 @@ async def _observer(event: OutputPopulatedEvent[IdOutputT]):
273273
if not event.is_transient:
274274
await reference_provider.append(event.session, event.output)
275275

276-
self._aggregate_provider.id_provider.on_populated.attach(_observer, id(self._aggregate_provider))
276+
self._aggregate_provider.id_provider.on_populated.attach(_observer, id(reference_provider))
277277

278278
return self._aggregate_provider
279279

0 commit comments

Comments
 (0)