Repository navigation

feat(async transport): Add Async Transport implementation - #4654

Closed

srothh wants to merge 164 commits into

potel-basefrom

srothh/complete-async-transport

Closed

feat(async transport): Add Async Transport implementation#4654
srothh wants to merge 164 commits into
potel-basefrom
srothh/complete-async-transport

Commits on Jul 21, 2025
Commits on Jul 23, 2025
- ref(transport): add async type annotations to HTTPTransportCore
  srothh
  committed
  0ba5a83
- ref(transport): Add abstract base class for worker implementation
  srothh
  committed
  9bb628e
- ref(transport): Add _create_worker factory method to Transport
  srothh
  committed
  a81487e
- ref(worker): Add flush_async method to Worker ABC
  srothh
  committed
  8960e6f
- ref(worker): Move worker flush_async from Worker ABC
  srothh
  committed
  0f7937b
- ref(worker): Amend function signature for coroutines
  srothh
  committed
  268ea1a
- feat(transport): Add an async task-based worker for transport
  srothh
  committed
  b3c05cc
- ref(worker): Make worker work with new ABC interface
  srothh
  committed
  fb0ad18
- fix(worker): Check if callbacks from worker queue are coroutines or functions
  srothh
  committed
  7edbbaf
- ref(worker): Amend return type of submit and flush to accomodate for coroutines
  srothh
  committed
  0f63d24
- ref(worker): Add type parameters for AsyncWorker variables
  srothh
  committed
  2430e2e
- ref(worker): Remove loop upon killing worker
  srothh
  committed
  96fcd85
- feat(worker): Enable concurrent callbacks on async task worker
  srothh
  committed
  331e40b
- fix(worker): Modify kill behaviour to mirror threaded worker
  srothh
  committed
  5f67485
- ref(worker): add proper type annotation to worker task list
  srothh
  committed
  97c5e3d
- feat(transport): Add async transport class
  srothh
  committed
  8809b08
- ref(transport): Fix event loop handling in async transport
  srothh
  committed
  7c5dec0
- feat(transport): Add kill method for async transport
  srothh
  committed
  b0390e6
- ref(transport): Fix type errors in async transport
  srothh
  committed
  f01b00d
Commits on Jul 24, 2025
- Add silent failing to kill on event loop errors
  srothh
  committed
  23b8ea2
- ref(transport): Fix event loop check in make_transport
  srothh
  committed
  176a1d1
- ref(transport): Add missing transport instantiation in non-async context
  srothh
  committed
  4fe61bf
Commits on Jul 25, 2025
- ref(transport): Fix httpcore async specific request handling
  srothh
  committed
  52c9e36
- ref(transport): Add gc safety to async kill
  srothh
  committed
  6d69406
- ref(transport): Add missing httpcore extensions
  srothh
  committed
  3629609
Commits on Jul 28, 2025
- fix(transport): Fix fallback sync transport creating async worker
  srothh
  committed
  21cde52
- ref(transport): Added shared sync/async transport superclass and created a sync transport HTTP subclass
  srothh
  committed
  cfed85d
- ref(transport) Removed Todo and reverted class name change
  srothh
  committed
  3fbb6da
- test(transport): Add test for HTTP error status handling
  srothh
  committed
  2f2cfdf
- test(transport): Restore accidentally removed comments
  srothh
  committed
  356e905
- ref(transport) Refactor class names to reflect previous functionality
  srothh
  committed
  781f7d2
- ref(transport): Add flush_async in the Transport abc
  srothh
  committed
  2135cd6
- ref(transport): Move flush_async from ABC
  srothh
  committed
  7916ab2
- ref(transport): add async type annotations to HTTPTransportCore
  srothh
  committed
  cb3c2a9
- ref(transport): Refactor transport class to restore former comments and cleaner return paths
  srothh
  committed
  5fd4317
- ref(transport): Add test for record_loss
  srothh
  committed
  4e56e5c
- ref(transport): Add abstract base class for worker implementation
  srothh
  committed
  9f24136
- ref(transport): Add _create_worker factory method to Transport
  srothh
  committed
  001f36c
- ref(worker): Add flush_async method to Worker ABC
  srothh
  committed
  401b1bc
- ref(worker): Move worker flush_async from Worker ABC
  srothh
  committed
  3f43d8f
- ref(worker): Amend function signature for coroutines
  srothh
  committed
  15fa295
- ref(worker): Add missing docstrings to worker ABC
  srothh
  committed
  ef780f3
Commits on Jul 29, 2025
- ref(transport): Make kill optionally return a task for async
  srothh
  committed
  c541bd7
- Integrate AsyncHttpTransport as a new experimental option
  srothh
  committed
  2808062
- ref(transport): Fix type issues in AsyncTransport
  srothh
  committed
  ea5f557
- ref(transport): Add missing async transport loop type annotation
  srothh
  committed
  c61eb02
- fix(client): Fix mypy type errors
  srothh
  committed
  38baead
- ref(client): Fix mypy inheritance type error
  srothh
  committed
  e4ed773
- ref(client): Move mypy annotations to correct place
  srothh
  committed
  236ae2c
- ref(client): Add event loop handling to client flush/close
  srothh
  committed
  9dd546c
- ref(client): Moved close done callback into async task
  srothh
  committed
  f4ac157
- ref(client): Move timeout check in client to properly cover async
  srothh
  committed
  ed392e9
- feat(asyncio): Add patching for loop.close in asyncio
  srothh
  committed
  50553d4
- ref(asyncio): Fix mypy type annotation errors
  srothh
  committed
  4a7b8ce
- ref(client): Fix redundant async flush helper flushes
  srothh
  committed
  cd8a35f
- ref(client): remove wrongful indent
  srothh
  committed
  b9f2ec7
- test(transport): Add inital transport tests
  srothh
  committed
  98d74ed
- fix(requirements): Fix requirements for async transport testing on python versions
  srothh
  committed
  9df5ec5
- fix(dependencies): Remove version constraint from httpcore
  srothh
  committed
  23d8740
- fix(dependencies): Version guards for correct httpcore version
  srothh
  committed
  a496787
- ref(tox): remove anyio version pin
  srothh
  committed
  32a9abd
- Revert "ref(tox): remove anyio version pin"
  srothh
  committed
  a69f7bb
- ref(dependencies): Revert dependency changes
  srothh
  committed
  c80b095
- ref(test): Remove flush from async transport test
  srothh
  committed
  5904968
- ref(client): Remove wrongful indents in client sync flush
  srothh
  committed
  09034b7
- fix(testing): Changed httpx anyio version pin to >=3, <5
  srothh
  committed
  21b1cda
- fix(test): Properly modify httpx anyio pin
  srothh
  committed
  9d0cde4
- fix(test): Add fastapi anyio pin for <0.8
  srothh
  committed
  f21e2ea
- feat(test): Add tests for specific async transport functionality
  srothh
  committed
  76aae83
- feat(test): Add flush to async transport test
  srothh
  committed
  4c1e99b
- ref(client): Adapt client for blocking kill in async transport
  srothh
  committed
  6df7037
- ref(client): Fix transport shutdown if loop is not running
  srothh
  committed
  25c04fc
- ref(test): Add config tests for SSL/proxy for async
  srothh
  committed
  e8d889c
Commits on Jul 30, 2025
- feat(transport): Add an async task-based worker for transport
  srothh
  committed
  f63e46f
- ref(worker): Make worker work with new ABC interface
  srothh
  committed
  1804271
- fix(worker): Check if callbacks from worker queue are coroutines or functions
  srothh
  committed
  11da869
- ref(worker): Amend return type of submit and flush to accomodate for coroutines
  srothh
  committed
  779a0d6
- ref(worker): Add type parameters for AsyncWorker variables
  srothh
  committed
  0895d23
- ref(worker): Remove loop upon killing worker
  srothh
  committed
  bbf426b
- feat(worker): Enable concurrent callbacks on async task worker
  srothh
  committed
  744dc8a
- fix(worker): Modify kill behaviour to mirror threaded worker
  srothh
  committed
  fcc8040
- ref(worker): add proper type annotation to worker task list
  srothh
  committed
  9a43d9b
- ref(worker): Refactor implementation to incorporate feedback
  srothh
  committed
  b5eda0e
- ref(worker): fix queue initialization
  srothh
  committed
  9e380b8
- ref(worker): Add queue as optional to allow for initialisation in start
  srothh
  committed
  ee44621
- ref(worker): Change to sync flush method that launches task
  srothh
  committed
  d9f7383
- feat(transport): Add async transport class
  srothh
  committed
  a644465
- ref(transport): Fix event loop handling in async transport
  srothh
  committed
  c935e9e
- feat(transport): Add kill method for async transport
  srothh
  committed
  b90daf4
- ref(transport): Fix type errors in async transport
  srothh
  committed
  e1d7cdb
- Add silent failing to kill on event loop errors
  srothh
  committed
  90346a5
- ref(transport): Fix event loop check in make_transport
  srothh
  committed
  47416f4
- ref(transport): Add missing transport instantiation in non-async context
  srothh
  committed
  73cdc6d
- ref(transport): Fix httpcore async specific request handling
  srothh
  committed
  1ae8708
- ref(transport): Add gc safety to async kill
  srothh
  committed
  6f18657
- ref(transport): Add missing httpcore extensions
  srothh
  committed
  87a9b2f
- fix(transport): Fix fallback sync transport creating async worker
  srothh
  committed
  4fd7fa0
- ref(transport): Make kill optionally return a task for async
  srothh
  committed
  69734cd
- ref(transport): Adapt transport for synchronous flush interface
  srothh
  committed
  f5ef707
- ref(transport): Fix mypy error
  srothh
  committed
  fca8740
- Merge branch 'srothh/async-transport' into srothh/async-transport-integration
  srothh
  committed
  4b0d09b
- ref(transport): Make client work with sync flush changes
  srothh
  committed
  e23efd7
- ref(worker): Readd coroutine check for worker callbacks
  srothh
  committed
  d2e647b
- ref(client): Properly add client changes for sync flush
  srothh
  committed
  55b606a
- feat(transport): Add async transport class
  srothh
  committed
  d89abed
- ref(transport): Fix event loop handling in async transport
  srothh
  committed
  5e1e0c6
- feat(transport): Add kill method for async transport
  srothh
  committed
  8fdf43d
- ref(transport): Fix type errors in async transport
  srothh
  committed
  6619670
- Add silent failing to kill on event loop errors
  srothh
  committed
  2eee1b1
- ref(transport): Fix event loop check in make_transport
  srothh
  committed
  6c787a4
- ref(transport): Add missing transport instantiation in non-async context
  srothh
  committed
  b79d346
- ref(transport): Fix httpcore async specific request handling
  srothh
  committed
  1717888
- ref(transport): Add gc safety to async kill
  srothh
  committed
  e1fd57a
- ref(transport): Add missing httpcore extensions
  srothh
  committed
  b87c68e
- fix(transport): Fix fallback sync transport creating async worker
  srothh
  committed
  a827d0d
- ref(transport): Make kill optionally return a task for async
  srothh
  committed
  ee0b440
- ref(transport): Adapt transport for synchronous flush interface
  srothh
  committed
  70f228e
- ref(transport): Fix mypy error
  srothh
  committed
  328d8ad
- ref(transport): Make transport loop public
  srothh
  committed
  ef61134
- Merge branch 'srothh/async-transport' into srothh/async-transport-integration
  srothh
  committed
  ad93516
- ref(transport): Add import checking for async transport
  srothh
  committed
  42d3a34
- ref(transport): Fix typing errors
  srothh
  committed
  10d85f6
- ref(transport): Fix import checking
  srothh
  committed
  aaae195
- Merge branch 'srothh/async-transport' into srothh/async-transport-integration
  srothh
  committed
  de47da2
- ref(client): Fix type checking with fallback asynctransport
  srothh
  committed
  6e2c4f6
Commits on Jul 31, 2025
- ref(asyncio): Refactor loop close patch in asyncio integration
  srothh
  committed
  9da7be8
- ref(client): Split client flush into seperate function for readability
  srothh
  committed
  8a5ab06
- ref(transport): Refactor async transport to be more aligned with sync
  srothh
  committed
  295a0e9
- Merge branch 'srothh/async-transport' into srothh/async-transport-integration
  srothh
  committed
  e754a85
- ref(worker): Remove sync callbacks from worker processing for now
  srothh
  committed
  859a0e2
- feat(transport): Add async transport class
  srothh
  committed
  4a58ce7
- ref(transport): Fix event loop handling in async transport
  srothh
  committed
  cbecde7
- feat(transport): Add kill method for async transport
  srothh
  committed
  c8bb55a
- ref(transport): Fix type errors in async transport
  srothh
  committed
  05a7de7
- Add silent failing to kill on event loop errors
  srothh
  committed
  38246d0
- ref(transport): Fix event loop check in make_transport
  srothh
  committed
  8b226cb
- ref(transport): Add missing transport instantiation in non-async context
  srothh
  committed
  823215e
- ref(transport): Fix httpcore async specific request handling
  srothh
  committed
  4eed4fd
- ref(transport): Add gc safety to async kill
  srothh
  committed
  afd494d
- ref(transport): Add missing httpcore extensions
  srothh
  committed
  fcc7ac3
- fix(transport): Fix fallback sync transport creating async worker
  srothh
  committed
  f659514
- ref(transport): Make kill optionally return a task for async
  srothh
  committed
  8c542ce
- ref(transport): Adapt transport for synchronous flush interface
  srothh
  committed
  30dde67
- ref(transport): Fix mypy error
  srothh
  committed
  3392e0e
- ref(transport): Make transport loop public
  srothh
  committed
  6c85500
- ref(transport): Add import checking for async transport
  srothh
  committed
  ae5a864
- ref(transport): Fix typing errors
  srothh
  committed
  9c537e6
- ref(transport): Fix import checking
  srothh
  committed
  f7554b2
- ref(transport): Refactor async transport to be more aligned with sync
  srothh
  committed
  6cb72ad
- Merge branch 'srothh/async-transport' into srothh/async-transport-integration
  srothh
  committed
  9f226cf
- Merge branch 'potel-base' into srothh/complete-async-transport
  srothh
  committed
  c44e671
Commits on Aug 1, 2025
- Merge branch 'potel-base' into srothh/complete-async-transport
  srothh
  committed
  35a9a72
Commits on Aug 5, 2025
Commits on Aug 6, 2025
- Merge branch 'potel-base' into srothh/complete-async-transport
  antonpirker
  authored
  b74454a

Commits

Commits on Jul 21, 2025

Commits on Jul 23, 2025

Commits on Jul 24, 2025

Commits on Jul 25, 2025

Commits on Jul 28, 2025

Commits on Jul 29, 2025

Commits on Jul 30, 2025

Commits on Jul 31, 2025