# Path: mrq/task.py
# class Task(object):
# 
#     # Are we the first task that a Job called?
#     is_main_task = False
#     max_concurrency = 0
# 
#     # Default write concern values when setting status=success
#     # http://docs.mongodb.org/manual/reference/write-concern/
#     status_success_update_w = None
#     status_success_update_j = None
# 
#     def __init__(self):
#         pass
# 
#     def run_wrapped(self, params):
#         """ Override this method to provide your own wrapping code """
#         return self.run(params)
# 
#     def run(self, params):
#         """ Override this method with the main code of all your tasks """
#         raise NotImplementedError
# 
# Path: mrq/context.py
# _GLOBAL_CONTEXT = {
# 
#     # Contains all the running greenlets for this worker. greenletid => Job object
#     "greenlets": {},
# 
#     # pointer to the current worker
#     "worker": None,
# 
#     # pointer to the current config
#     "config": {}
# }
# def setup_context(**kwargs):
# def set_current_job(job):
# def get_current_job(greenlet_id=None):
# def set_current_worker(worker):
# def get_current_worker():
# def set_logger_config():
# def set_current_config(config):
# def get_current_config():
# def retry_current_job(delay=None, max_retries=None, queue=None):
# def abort_current_job():
# def _connections_factory(attr):
#     def versiontuple(v):
# def enable_greenlet_tracing():
#     def trace(*args):
# def run_task(path, params):
# def set_current_job_progress(ratio, save=False):
# def queue_raw_jobs(*args, **kwargs):
# def queue_job(*args, **kwargs):
# def queue_jobs(*args, **kwargs):
# def metric(*args, **kwargs):


from future import standard_library
from mrq.task import Task
from mrq.context import connections, log
from future.moves.urllib.request import urlopen
import ssl
import urllib.request, urllib.error, urllib.parse
            import requests
standard_library.install_aliases()

# Evil workaround to disable SSL verification
ctx = ssl.create_default_context()
ctx.check_hostname = False
ctx.verify_mode = ssl.CERT_NONE



class TestIo(Task):

    def run(self, params):

        log.info("I/O starting")
        ret = self._run(params)

# Path: mrq/task.py
# class Task(object):
# 
#     # Are we the first task that a Job called?
#     is_main_task = False
#     max_concurrency = 0
# 
#     # Default write concern values when setting status=success
#     # http://docs.mongodb.org/manual/reference/write-concern/
#     status_success_update_w = None
#     status_success_update_j = None
# 
#     def __init__(self):
#         pass
# 
#     def run_wrapped(self, params):
#         """ Override this method to provide your own wrapping code """
#         return self.run(params)
# 
#     def run(self, params):
#         """ Override this method with the main code of all your tasks """
#         raise NotImplementedError
# 
# Path: mrq/context.py
# _GLOBAL_CONTEXT = {
# 
#     # Contains all the running greenlets for this worker. greenletid => Job object
#     "greenlets": {},
# 
#     # pointer to the current worker
#     "worker": None,
# 
#     # pointer to the current config
#     "config": {}
# }
# def setup_context(**kwargs):
# def set_current_job(job):
# def get_current_job(greenlet_id=None):
# def set_current_worker(worker):
# def get_current_worker():
# def set_logger_config():
# def set_current_config(config):
# def get_current_config():
# def retry_current_job(delay=None, max_retries=None, queue=None):
# def abort_current_job():
# def _connections_factory(attr):
#     def versiontuple(v):
# def enable_greenlet_tracing():
#     def trace(*args):
# def run_task(path, params):
# def set_current_job_progress(ratio, save=False):
# def queue_raw_jobs(*args, **kwargs):
# def queue_job(*args, **kwargs):
# def queue_jobs(*args, **kwargs):
# def metric(*args, **kwargs):


# Path: tests/tasks/io.py
from future import standard_library
from mrq.task import Task
from mrq.context import connections, log
from future.moves.urllib.request import urlopen
import ssl
import urllib.request, urllib.error, urllib.parse
            import requests

standard_library.install_aliases()

# Evil workaround to disable SSL verification
ctx = ssl.create_default_context()
ctx.check_hostname = False
ctx.verify_mode = ssl.CERT_NONE



class TestIo(Task):

    def run(self, params):

        log.info("I/O starting")
        ret = self._run(params)

        log.info("I/O finished")