o [h@sddlZddlmZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z mZddlZddlmZeZeeZd efd d Zd d ZGdddZddZddZddZdS)N) getLogger)sleep)requestparse)URLError)urljoin)db session_scope)TaskQueueMessagedatacCs*t|}tj||d}t|}dS)z make the request over the network rather than in-process, to avoid race conditions. everything must be handled by the main server instance. r N)r urlencodeencoderRequesturlopen)urlr reqresprr/home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/otree/tasks.pypostsrc CsDzt|WdSty!}z td|dt|dd}~ww)NzError occurred when opening z: )rrr Exceptionrepr)rexcrrrgets rc@s,eZdZddZddZddZddZd S) WorkercCs,d||_ttjtdkdS)Nzhttp://127.0.0.1:<)base_urlr objects_filter epoch_timetimedelete)selfportrrr__init__&s  zWorker.__init__c Cstd tFttjtkdD]0}zt||jdi| Wnt y@}z t t |WYd}~nd}~wwt|qWdn1sQwYtdq)Nz2timeoutworker is listening for messages through DBTrr)print_functionr r rrr Zorder_bygetattrmethodkwargsrlogger exceptionrrr!r)r"taskrrrrlisten.s&   z Worker.listencCs^ddlm}|j||d}|r-|}td|tt|j |t j j diddSdS)Nr Participant)code_index_in_pages Auto-submitting timed out page: Tr ) otree.models.participantr/rfirst_url_i_should_be_onr*inforrrotree constantsZtimeout_happened)r"Zparticipant_code page_indexr/pppathrrrsubmit_expired_urlAs    zWorker.submit_expired_urlcCs`ddlm}||j||j|dk}|D]}|}td|t t |j |qdS)a7This is necessary when a wait page is followed by a timeout page. We can't guarantee the user's browser will properly continue to poll the wait page and get redirected, so after a grace period we load the page automatically, to kick off the expiration timer of the timeout page. rr.r2N) r3r/ridin_r1r5r*r6rrr)r"Zparticipant_pksr9r/Zunvisited_participantsr:r;rrrensure_pages_visited\s   zWorker.ensure_pages_visitedN)__name__ __module__ __qualname__r$r-r<r@rrrrr%s  rcCs&tj||ttt|ddS)N)r(rZ kwargs_json)r Zobjects_createroundr jsondumpsr(delayr)rrr _db_enqueue{s  rIcKtd||ddS)Nr@rGrIrHr)rrrr@r@cKrJ)Nr<rGrKrLrrrr<rMr<)rEloggingrr rurllibrr urllib.errorr urllib.parserZotree.databaserr Zotree.constantsr7Zotree.models_concreter printr&rAr*dictrrrrIr@r<rrrrs$      V