diff --git a/pkg/database/postgres.go b/pkg/database/postgres.go
index c283bea..14c4003 100644
--- a/pkg/database/postgres.go
+++ b/pkg/database/postgres.go
@@ -54,7 +54,7 @@ func (p *postgresqlConnection) Connect(_ context.Context, endpoint string, usern
 }
 
 func (p *postgresqlConnection) AddUserWithRelationToSource(ctx context.Context, anthroveUserID models.AnthroveUserID, sourceDomain string, userID string, username string) error {
-	return postgres.CreateUserNodeWithSourceRelation(ctx, p.db, anthroveUserID, userID, sourceDomain, userID)
+	return postgres.CreateUserNodeWithSourceRelation(ctx, p.db, anthroveUserID, sourceDomain, userID, userID)
 }
 
 func (p *postgresqlConnection) AddSource(ctx context.Context, anthroveSource *graphModels.AnthroveSource) error {