View all skypy analysis

How to use the skypy.remove_ref_dependency function in skypy

To help you get started, we’ve selected a few skypy examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

mrry / ciel / src / python / skywriting / runtime / worker / skypy / ref_fetch.py View on Github

def close(self):
        self.fp.close()
        if self.must_close:
            skypy.current_task.message_helper.send_message("close_stream", {"id": self.ref.id, "chunk_size": self.chunk_size})            
        skypy.remove_ref_dependency(self.ref)

mrry / ciel / src / python / skywriting / runtime / worker / skypy / ref_fetch.py View on Github

def close(self):
        self.closed = True
        self.fp.close()
        skypy.current_task.message_helper.send_message("close_stream", {"id": self.ref.id, "chunk_size": self.chunk_size})
        skypy.remove_ref_dependency(self.ref)