def METHOD_NAME(self, connection_with_udf):
    """
    Invoke job_info() with correct policy and an expected timeout
    """
    policy = {"timeout": 1}
    self.job_id = connection_with_udf.scan_apply("test", "demo", "bin_lua", "mytransform", ["age", 2], block=False)
    with pytest.raises(e.TimeoutError):
        self.as_connection.job_info(self.job_id, aerospike.JOB_SCAN, policy)