<commit_before>
__author__    = "<NAME>"
__copyright__ = "Copyright 2012-2013, The SAGA Project"
__license__   = "MIT"


""" This examples shows how to run a job on a remote SGE cluster
    using the 'SGE' job adaptor.

    More information about the saga-python job API can be found at:
    http://saga-project.github.com/saga-python/doc/library/job/index.html
"""

import sys
import saga
import getpass


def main():

    try:
        # Your ssh identity on the remote machine.
        ctx = saga.Context("ssh")
        ctx.user_id = getpass.getuser()  # Change if necessary

        session = saga.Session()
        session.add_context(ctx)

        # Create a job service object that represent a remote pbs cluster.
        # The keyword 'pbs' in the url scheme triggers the SGE adaptors
        # and '+ssh' enables SGE remote access via SSH.
        js = saga.job.Service("sge+ssh://lonestar.tacc.utexas.edu",
                              session=session)

        # Next, we describe the job we want to run. A complete set of job
        # description attributes can be found in the API documentation.
        jd = saga.job.Description()
        jd.queue           = 'development'
        jd.project         = 'TG-MCB090174'
        jd.total_cpu_count = 12 # for lonestar this has to be a multiple of 12
        jd.spmd_variation  = '12way' # translates to the qsub -pe flag
        jd.environment     = {'RUNTIME': '10'}
        jd.wall_time_limit = 1 # minutes
        jd.executable      = '/bin/sleep'
        jd.arguments       = ['$RUNTIME']

        # Create a new job from the job description. The initial state of <commit_msg>snapshot<commit_after>
__author__    = "<NAME>"
__copyright__ = "Copyright 2012-2013, The SAGA Project"
__license__   = "MIT"


""" This examples shows how to run a job on a remote SGE cluster
    using the 'SGE' job adaptor.

    More information about the saga-python job API can be found at:
    http://saga-project.github.com/saga-python/doc/library/job/index.html
"""

import sys
import saga
import getpass


def main():

    try:
        # Your ssh identity on the remote machine.
        ctx = saga.Context("ssh")
        #ctx.user_id = getpass.getuser()  # Change if necessary

        session = saga.Session()
        session.add_context(ctx)

        # Create a job service object that represent a remote pbs cluster.
        # The keyword 'pbs' in the url scheme triggers the SGE adaptors
        # and '+ssh' enables SGE remote access via SSH.
        js = saga.job.Service("sge+ssh://lonestar.tacc.utexas.edu",
                              session=session)

        # Next, we describe the job we want to run. A complete set of job
        # description attributes can be found in the API documentation.
        jd = saga.job.Description()
        jd.queue           = 'development'
        jd.project         = 'TG-MCB090174'
        jd.total_cpu_count = 12 # for lonestar this has to be a multiple of 12
        jd.spmd_variation  = '12way' # translates to the qsub -pe flag
        jd.environment     = {'RUNTIME': '10'}
        jd.wall_time_limit = 1 # minutes
        jd.executable      = '/bin/sleep'
        jd.arguments       = ['$RUNTIME']

        # Create a new job from the job description. The initial state of 
{'fraction_non_alphanumeric': 0.08932926829268292, 'fraction_numerical': 0.01402439024390244, 'mean_word_length': 2.2009756097560977, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7451136', 'n_tokens_mistral': 1031, 'n_tokens_neox': 931, 'n_words': 342}