snipy/activeq.py
def put_job(self, fun, *args, **kwargs):
        """
        put job if possible, non-blocking
        :param fun:
        :param args:
        :param kwargs:
        :return:
        """
        if not args and not kwargs and isinstance(fun, (tuple, list)):
            # ex) q.put_job([fun, args, kwargs])
            fun, args, kwargs = fun

        assert callable(fun)
        return self.put((fun, args, kwargs), block=False)
def put_job(self, fun, *args, **kwargs):
        """
        put job if possible, non-blocking
        :param fun:
        :param args:
        :param kwargs:
        :return:
        """
        if not args and not kwargs and isinstance(fun, (tuple, list)):
            # ex) q.put_job([fun, args, kwargs])
            fun, args, kwargs = fun

        assert callable(fun)
        return self.put((fun, args, kwargs), block=False)
def put_job ( self , fun , * args , * * kwargs ) : if not args and not kwargs and isinstance ( fun , ( tuple , list ) ) : # ex) q.put_job([fun, args, kwargs]) fun , args , kwargs = fun assert callable ( fun ) return self . put ( ( fun , args , kwargs ) , block = False )
put job if possible, non-blocking
        :param fun:
        :param args:
        :param kwargs:
        :return:
put job if possible non - blocking : param fun : : param args : : param kwargs : : return :