human
Solve the following python programming problem given the following code:
def _init() : 
    global _conn_details, _initialized, _serializer 
    assert (not _initialized), 'already initialized' 
    if (not zmq) : 
        raise RuntimeError ('zmq not available') 
_serializer = Serializer () 
    context = zmq.Context () 
    sink = None 
    source = None 
    if ('MDF_REMOTE_MESSAGING_ADDR' not in os.environ) : 
        sink = context.socket (zmq.PULL) 
        port = sink.bind_to_random_port ('tcp://*') 
        _log.debug (('Listening on tcp://localhost:%d' % port)) 
        os.environ ['MDF_REMOTE_MESSAGING_ADDR'] = ('tcp://localhost:%d' % port) 
else : 
        address = os.environ ['MDF_REMOTE_MESSAGING_ADDR'] 
        source = context.socket (zmq.PUSH) 
        source.connect (address) 
_conn_details = ConnectionDetails (context = context, sink = cleanup_sockets, source = source) 
    _initialized = True 
    @ atexit.register 
    def cleanup_sockets() : 
        _conn_details.sink.close () 

    
    

    Fix the buggy line: _conn_details = ConnectionDetails (context = context, sink = cleanup_sockets, source = source)
assistant
#Here is Python program to fix the buggy line: _conn_details = ConnectionDetails (context = context, sink = cleanup_sockets, source = source)
.

_conn_details = ConnectionDetails (context = context, sink = sink, source = source)