Need help with connect to self host camunda

[manh7890]

Hi i just self host a camunda and try to connect to it with pyzeebe but i keep getting error
Failed to activate jobs from the gateway. Exception: ZeebeGatewayUnavailableError(grpc_error=AioRpcError(code=StatusCode.UNAVAILABLE, details=failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.0.1:26500: Ssl handshake failed (TSI_PROTOCOL_FAILURE): SSL_ERROR_SSL: error:100000f7:SSL routines:OPENSSL_internal:WRONG_VERSION_NUMBER: Invalid certificate verification context, debug_error_string=UNKNOWN:Error received from peer {created_time:"2025-05-22T17:33:02.837885631+07:00", grpc_status:14, grpc_message:"failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.0.1:26500: Ssl handshake failed (TSI_PROTOCOL_FAILURE): SSL_ERROR_SSL: error:100000f7:SSL routines:OPENSSL_internal:WRONG_VERSION_NUMBER: Invalid certificate verification context"})).
when i use create_oauth2_client_credentials_channel to connect to zeebe gate way and get error
pyzeebe.errors.zeebe_errors.UnknownGrpcStatusCodeError: UnknownGrpcStatusCodeError(grpc_error=AioRpcError(code=StatusCode.UNAUTHENTICATED, details=Expected bearer token at header with key [authorization], but found nothing, debug_error_string=UNKNOWN:Error received from peer {grpc_message:"Expected bearer token at header with key [authorization], but found nothing", grpc_status:16, created_time:"2025-05-22T17:31:42.927624776+07:00"}))
if i use create_insecure_channel If any want know how to fix or did i make some config wrong please help

[manh7890]

i have get the token and connect to the client by use
`
class AuthInterceptor(UnaryUnaryClientInterceptor, UnaryStreamClientInterceptor,
StreamUnaryClientInterceptor, StreamStreamClientInterceptor):
def init(self, token):
self.metadata = (("authorization", f"Bearer {token}"),)

async def intercept_unary_unary(self, continuation, client_call_details, request):
    new_details = self._inject_metadata(client_call_details)
    return await continuation(new_details, request)

async def intercept_unary_stream(self, continuation, client_call_details, request):
    new_details = self._inject_metadata(client_call_details)
    return await continuation(new_details, request)

async def intercept_stream_unary(self, continuation, client_call_details, request_iterator):
    new_details = self._inject_metadata(client_call_details)
    return await continuation(new_details, request_iterator)

async def intercept_stream_stream(self, continuation, client_call_details, request_iterator):
    new_details = self._inject_metadata(client_call_details)
    return await continuation(new_details, request_iterator)

def _inject_metadata(self, client_call_details):
    # Use _replace method for named tuples instead of constructor
    if client_call_details.metadata is None:
        metadata = self.metadata
    else:
        metadata = client_call_details.metadata + self.metadata
    
    return client_call_details._replace(metadata=metadata)
    
     options = [
        ('grpc.default_authority', gateway_address),
        ('grpc.primary_user_agent', 'pyzeebe-client'),
        ('grpc.max_receive_message_length', 100 * 1024 * 1024),  # 100MB max message size
    ]
    
    # Get token if credentials are provided
    if credentials and 'client_id' in credentials and 'client_secret' in credentials:
        self._token = self._get_token(credentials)
        interceptors = [AuthInterceptor(self._token)]
    else:
        self._token = None
        interceptors = []
    
    # Create channel based on connection type
    if use_plaintext:
        channel = aio.insecure_channel(gateway_address, options=options, interceptors=interceptors)
    else:
        # Create secure channel with SSL credentials
        channel = aio.secure_channel(gateway_address, 
                                    credentials=ssl_channel_credentials(),
                                    options=options,
                                    interceptors=interceptors)
        
    # Create the actual PyZeebe client
    self._client = PyZeebeClient(channel)
    `
    
    it work find but when i put that channel  to ZeebeWorker it all way show me 
    `
    future: <Task finished name='Task-2' coro=<ZeebeWorker.work() done, defined at /home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/worker/worker.py:103> exception=ExceptionGroup('unhandled errors in a TaskGroup', [UnknownGrpcStatusCodeError(grpc_error=AioRpcError(code=StatusCode.UNAUTHENTICATED, details=Expected bearer token at header with key [authorization], but found nothing, debug_error_string=UNKNOWN:Error received from peer  {created_time:"2025-05-23T13:42:20.553901536+07:00", grpc_status:16, grpc_message:"Expected bearer token at header with key [authorization], but found nothing"}))])>

• Exception Group Traceback (most recent call last):
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/worker/worker.py", line 117, in work
  | async with anyio.create_task_group() as tg:
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py", line 772, in aexit
  | raise BaseExceptionGroup(
  | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
  +-+---------------- 1 ----------------
  | Traceback (most recent call last):
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/grpc_internals/zeebe_job_adapter.py", line 49, in activate_jobs
  | async for response in self._gateway_stub.ActivateJobs(
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/grpc/aio/_call.py", line 365, in _fetch_stream_responses
  | await self._raise_for_status()
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/grpc/aio/_call.py", line 272, in _raise_for_status
  | raise _create_rpc_error(
  | grpc.aio._call.AioRpcError: <AioRpcError of RPC that terminated with:
  | status = StatusCode.UNAUTHENTICATED
  | details = "Expected bearer token at header with key [authorization], but found nothing"
  | debug_error_string = "UNKNOWN:Error received from peer {created_time:"2025-05-23T13:42:20.553901536+07:00", grpc_status:16, grpc_message:"Expected bearer token at header with key [authorization], but found nothing"}"
  | >
  |
  | During handling of the above exception, another exception occurred:
  |
  | Traceback (most recent call last):
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/worker/job_poller.py", line 46, in poll
  | await self.activate_max_jobs()
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/worker/job_poller.py", line 50, in activate_max_jobs
  | await self.poll_once()
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/worker/job_poller.py", line 70, in poll_once
  | async for job in jobs:
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/grpc_internals/zeebe_job_adapter.py", line 68, in activate_jobs
  | await self._handle_grpc_error(grpc_error)
  | File "/home/ubuntu/.local/lib/python3.12/site-packages/pyzeebe/grpc_internals/zeebe_adapter_base.py", line 44, in _handle_grpc_error
  | raise pyzeebe_error
  | pyzeebe.errors.zeebe_errors.UnknownGrpcStatusCodeError: UnknownGrpcStatusCodeError(grpc_error=AioRpcError(code=StatusCode.UNAUTHENTICATED, details=Expected bearer token at header with key [authorization], but found nothing, debug_error_string=UNKNOWN:Error received from peer {created_time:"2025-05-23T13:42:20.553901536+07:00", grpc_status:16, grpc_message:"Expected bearer token at header with key [authorization], but found nothing"}))
  +-----------------------------------
  `