ruescasd

// optionally filter on a column with a supplied predicate
case class MaybeFilter[X, Y](val query: scala.slick.lifted.Query[X, Y]) {
  def filter[T](data: Option[T])(f: T => X => scala.slick.lifted.Column[Boolean]) = {
    data.map(v => MaybeFilter(query.filter(f(v)))).getOrElse(this)
  }
}

// example use case
def find(id: Option[Int], createdMin: Option[Date], createdMax: Option[Date], modifiedMin: Option[Date], modifiedMax: Option[Date]) = {

ruescasd

def ratioTrend3(ratioMin: Double, ratioMax: Double, vertices: Int, questions: Int, maxQuestions: Int, inc: Double = 0.5) = {
        val ratios = for {
            r <- ratioMin until (ratioMax, inc) 
            q <- 1 until maxQuestions
        } yield(r, q)
        
        val values = ratios.map{ rq =>             
            val graph = getRandomGraph(vertices, rq._1)
            val lfa = new Lfa2(questions, graph)
            println(lfa.maxScore)

ruescasd

(0 to questions-1).flatMap{ i =>

    // calculate coverage of this question: we go through each vertex,
    // and see if it has been assigned to answer to this question, or
    // if a neighbour vertex (i.e. a delegate) has
    vertexList.zipWithIndex.map{case(vertex, j) =>
        if (assignments.get(j) == i) 1
        else {
            var incoming = graph.incomingEdgesOf(vertex)
            incoming.map{edge =>

ruescasd

bullboard basic readdata res false
bullboard basic readdata
http client: url http://piratamad-auth:4081/1/Protocol.302d32653135336161332d313030632d343430302d386335392d633233376435656533613366/BullBoard.BullBoard/Synchronize
java.net.ConnectException: Connection refused
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
        at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
        at java.net.Socket.connect(Socket.java:579)

ruescasd

Traceback (most recent call last):
  File "build/bdist.linux-x86_64/egg/apscheduler/scheduler.py", line 471, in _run_job
    retval = job.func(*job.args, **job.kwargs)
  File "build/bdist.linux-x86_64/egg/frestq/api.py", line 48, in call_action_handler
    msg = Message.query.get(msg_id)
  File "/home/eorchestra/venv/local/lib/python2.7/site-packages/sqlalchemy/orm/query.py", line 816, in get
    return loading.load_on_ident(self, key)
  File "/home/eorchestra/venv/local/lib/python2.7/site-packages/sqlalchemy/orm/loading.py", line 230, in load_on_ident
    return q.one()
  File "/home/eorchestra/venv/local/lib/python2.7/site-packages/sqlalchemy/orm/query.py", line 2355, in one

ruescasd

DEBUG:root:The MESSAGE is NOT LOCAL and with id 99c06dda-34a3-4666-aebf-e7de7a6b94cc
/home/eorchestra/venv/local/lib/python2.7/site-packages/sqlalchemy/engine/default.py:574: SAWarning: Unicode type received non-unicode bind param value.
  processors[key](compiled_params[key])
/home/eorchestra/venv/local/lib/python2.7/site-packages/sqlalchemy/sql/type_api.py:860: SAWarning: Unicode type received non-unicode bind param value.
  return impl_processor(process_param(value, dialect))
ERROR:frestq.app:Exception on /api/queues/orchestra_performer/ [POST]
Traceback (most recent call last):
  File "/home/eorchestra/venv/local/lib/python2.7/site-packages/flask/app.py", line 1817, in wsgi_app
    response = self.full_dispatch_request()
  File "/home/eorchestra/venv/local/lib/python2.7/site-packages/flask/app.py", line 1477, in full_dispatch_request

ruescasd

ssh-rsa AAAAB3NzaC1yc2EAAAABIwAAAQEAyDwFARi/K6fMag5CScGfbeF96WAEa1sMQsbNmWNA/4Y1T9L2f5jWRp9E2MkPTA+YFUgLoEDeFBx+3q/g7xzBrFzjfvBhuu3cu5l/s2LjGoGBL0TInh1E5v8A7GULUUr7ra5SfIkEWCJPgpRPhE2sEAp7vQ7aW57GAmPRDVZ09Cv+7Zy/mF3IgMeODhjXl9OS9TXxk4q8D2+UKaXZl8h/h6Pa6JTc2AxJcUf4Aicm6qL/+XmhDSk31UYldS/UmvOV/iCv5AjqkJzz5wotI6k6ZOsuYupbu3SQ2SZwgPXpllWHkz22eZIQM7oHywA/tjJO3iLOVP5HG3r1iJAg3+EIEQ== David@DAVID-PC

ruescasd

filters=[]
    filters.append(getattr(Task, "task_type").__eq__("external"))
    filters.append(getattr(Task, "status").__eq__("executing"))
    tasks = db.session.query(Task).filter(*filters)
    for task in tasks:
        print task.label
        print(type(task))
        print(type(task.input_data))

    print("**********************")

ruescasd

filters=[]
    filters.append(getattr(Task, "task_type").__eq__("external"))
    filters.append(getattr(Task, "status").__eq__("executing"))
    tasks = db.session.query(Task).filter(*filters)
    for task in tasks:
        print task.label
        print(type(task))
        print(type(task.input_data))
        print(task.input_data)

ruescasd

for question in data['result']['counts']:
        if "APPROVAL" not in question['a']:
            continue
        women = [a for a in question['answers'] if a['value'] in women_names]
        men = [a for a in question['answers'] if a['value'] not in women_names]
        
        answers_sorted = []
        
        if women[0]['value'] == question['answers'][0]['value']:
           men.insert(0, None)