Skip to content

Instantly share code, notes, and snippets.

View ruescasd's full-sized avatar

David Ruescas ruescasd

  • Sequent
View GitHub Profile
ssh-rsa AAAAB3NzaC1yc2EAAAABIwAAAQEAyDwFARi/K6fMag5CScGfbeF96WAEa1sMQsbNmWNA/4Y1T9L2f5jWRp9E2MkPTA+YFUgLoEDeFBx+3q/g7xzBrFzjfvBhuu3cu5l/s2LjGoGBL0TInh1E5v8A7GULUUr7ra5SfIkEWCJPgpRPhE2sEAp7vQ7aW57GAmPRDVZ09Cv+7Zy/mF3IgMeODhjXl9OS9TXxk4q8D2+UKaXZl8h/h6Pa6JTc2AxJcUf4Aicm6qL/+XmhDSk31UYldS/UmvOV/iCv5AjqkJzz5wotI6k6ZOsuYupbu3SQ2SZwgPXpllWHkz22eZIQM7oHywA/tjJO3iLOVP5HG3r1iJAg3+EIEQ== David@DAVID-PC
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
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
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)
(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 =>
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)
// 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]) = {
Podemos enforcarlo como una media ponderada, donde las ponderaciones son una especie de serie geometria, pero con probabilidades que varian. El exito en tiempo T require fracasos para t < T y exito en t = T.
Asi que tenemos que
P(Sucess = T) = Failure(0) * Failure(1) * ... * Failure(t-1) * Sucess(t)
y tambien sabemos que
Failure(t) = 1 - Sucess(t)
def do_dirtally(dir_path):
res_path = os.path.join(dir_path, 'result_json')
with codecs.open(res_path, encoding='utf-8', mode='r') as res_f:
result = json.loads(res_f.read())
return do_tally(dir_path, result['counts'])
david@david-VirtualBox:~/projects/agora-verifier/dir$ ls
agora_tally do_tally.py openstv tally.tar.gz
david@david-VirtualBox:~/projects/agora-verifier/dir$ python do_tally.py tally.tar.gz
Traceback (most recent call last):
File "do_tally.py", line 6, in <module>
print tally.do_tartally(sys.argv[1])
File "/home/david/projects/agora-verifier/dir/agora_tally/tally.py", line 53, in do_tartally
return do_tally(dir_path, result['counts'])
File "/home/david/projects/agora-verifier/dir/agora_tally/tally.py", line 65, in do_tally
voting_system = get_voting_system_by_id(tally_type)