'Get information on operations currently running.
:Parameters:
- `include_all` (optional): if ``True`` also list currently
idle operations in the result'

def current_op(self, include_all=False):

    cmd = SON([('currentOp', 1), ('$all', include_all)])
    with self.__client._socket_for_writes() as sock_info:
        if (sock_info.max_wire_version >= 4):
            return sock_info.command('admin', cmd)
        else:
            spec = ({'$all': True} if include_all else {})
            x = helpers._first_batch(sock_info, 'admin', '$cmd.sys.inprog', spec, (-1), True, self.codec_options, ReadPreference.PRIMARY, cmd, self.client._event_listeners)
            return x.get('data', [None])[0]
