mark-burnett

{
    "$schema": "http://json-schema.org/draft-04/schema#",
    "title": "POST /v1/workflows",

    "definitions": {
        "name": {
            "type": "string",
            "minLength": 1
        },

mark-burnett

package Genome::InstrumentData::Command::Import::Basic;

use Genome::InstrumentData::Command::Import::WorkflowBuilder;

# <snip>

sub execute {
    # <snip>

    # Instead of Workflow::Simple::run_workflow

mark-burnett

class AuthException(Exception): pass
class MissingAuthHeader(AuthException): pass
class MissingIdentHeader(AuthException): pass
class InvalidBearerToken(AuthException): pass


class ProtectedEndpoint(object):
    def __init__(self, realm=None, scopes=None, claims=None, aud=None):
        self._exception_map = _setup_exception_map(realm, scopes, claims, aud)
        self.target = None

mark-burnett

#!/usr/bin/env ruby

require 'rubygems'
require 'bundler/setup'

require 'json'
require 'ruote'

require 'amqp'
require 'ruote-amqp'

mark-burnett

require 'rubygems'
require 'ruote'

$start_time = nil 
$stop_time = nil 

class StartTime
  include Ruote::LocalParticipant

  def on_workitem

mark-burnett

require 'amqp'
require 'drmaa'
require 'json'

AMQP.settings[:user] = 'guest'
AMQP.settings[:pass] = 'guest'
AMQP.settings[:host] = 'localhost'
AMQP.settings[:vhost] = '/development/workflow'

$command_wrapper_path = '/home/vagrant/rw/workflow-grid-service/command_wrapper'