| 623 | if pool is None: |
| 624 | |
| 625 | def connect( |
| 626 | connection_record: Optional[ConnectionPoolEntry] = None, |
| 627 | ) -> DBAPIConnection: |
| 628 | if dialect._has_events: |
| 629 | mutable_cargs = list(cargs_tup) |
| 630 | mutable_cparams = dict(cparams) |
| 631 | for fn in dialect.dispatch.do_connect: |
| 632 | connection = cast( |
| 633 | DBAPIConnection, |
| 634 | fn( |
| 635 | dialect, |
| 636 | connection_record, |
| 637 | mutable_cargs, |
| 638 | mutable_cparams, |
| 639 | ), |
| 640 | ) |
| 641 | if connection is not None: |
| 642 | return connection |
| 643 | return dialect.connect(*mutable_cargs, **mutable_cparams) |
| 644 | else: |
| 645 | return dialect.connect(*cargs_tup, **cparams) |
| 646 | |
| 647 | creator = pop_kwarg("creator", connect) |
| 648 | |