Method am_i_owner

apps/proxy/live_proxy/server.py:445–448

Check if this worker is the owner of the channel

(self, channel_id)

            return None

    def am_i_owner(self, channel_id):
        """Check if this worker is the owner of the channel"""
        owner = self.get_channel_owner(channel_id)
        return owner == self.worker_id

    def try_acquire_ownership(self, channel_id, ttl=30):
        """Try to become the owner of this channel using proper locking"""