Aby uzyskać dostęp do infrastruktury QosCosGrid należy aplikować o odpowiednią usługę za pośrednictwem Portalu. W sekcji Usługi globalne zakładki Moje konto znajduje się lista usług. Wybrać należy odnośnik Aplikuj o usługę widoczny przy pozycji Globalny dostęp QosCosGrid.
Dla wygody użytkowników klient usługi QCG-Broker zainstalowany został na ogólnodostępnej (dla użytkowników infrastruktury QCG) maszynie.
Adres maszyny: qcg.man.poznan.pl
Typ dostępu: ssh
Użytkownik i hasło są takie same jak w portalu PL-Grid.
Jednocześnie, maszyna dostępowa QCG udostępnia przestrzeń dyskową poprzez protokół gridFTP. Przestrzeń ta może być wykorzystana zarówno do przechowywania plików wejściowych, jak i wyników eksperymentów.
Logowanie: ssh <plguser>@qcg.man.poznan.pl
np.
Zlecany plik jest plikiem tekstowym, który może zawierać dyrektywy infrastruktury QCG.
Dyrektywą jest każda linia zaczynająca się od ”#QCG”.
queue
note
name
output
error
input
host
stage-in-file
- stage-in-file - dyrektywa kopiowania pliku wejściowego. Składnia „lokalizacja_źródłowa → nazwa_docelowa_pliku”. Lokalizacja źródłowa może być lokalizacją gsiftp lub ścieżką do pliku. W tym drugim przypadku zakłada się, że jest ustalana względem katalogu, z którego zlecono zadanie.
W przypadku braku drugiego parametru plik kopiowany jest pod nazwę źródlową.
#QCG stage-in-file=gsiftp://qcg.man.poznan.pl//home/plgrid/plgpiontek/reef/inputs/input.txt -> input.txt
#QCG stage-in-file=gsiftp://qcg.man.poznan.pl//home/plgrid/plgpiontek/reef/inputs/input.txt
#QCG stage-in-file=input_file.txt -> input.txt
#QCG stage-in-file=input_file.txt
|
stage-in-dir
stage-out-file
stage-out-file - dyrektywa kopiowania pliku wyjściowego. Składnia „nazwa_pliku_źródłowego → lokalizacja docelowa pliku”. Lokalizacja docelowa może być lokalizacją gsiftp lub ścieżką do pliku. W tym drugim przypadku zakłada się, że jest ustalana względem katalogu, z którego zlecono zadanie. W przypadku braku drugiego parametry plik przegrywany jest pod nazwę źródłową.
#QCG stage-out-file=results.txt -> gsiftp://qcg.man.poznan.pl//home/plgrid/plgpiontek/reef/results/result.1
#QCG stage-out-file=results.txt
#QCG stage-out-file=result.txt -> ${JOB_ID}.result
#QCG stage-out-file=result.txt
|
stage-out-dir
grant
argument
environment
executable
executable - lokalizacja pliku do uruchomienia. Lokalizacja może być lokalizacją gsiftp lub ścieżką do pliku. W tym drugim przypadku przyjmuje się, że jest ustalana względem katalogu, z którego zlecone zostało zadanie. Opcjonalnie możliwe jest podanie nazwy pod jaką ma być zapisany plik wykonywalny. W przypadku braku nazwy zapisywany jest pod oryginalna nazwą.
#QCG executable=gsiftp://qcg.man.poznan.pl//home/plgrid/plgpiontek/reef/executables/exec1
#QCG executable=executables/exec1
#QCG executable=executables/exec1 -> exec-file
|
application
persistent
procs
nodes
nodes - dyrektywa pozwalająca zdefiniować na ilu węzłach i rdzeniach w ramach węzła ma być uruchomione zadanie. Opcjonalnie można podać ile procesów ma być uruchomione na węzłach. Domyślnie, jeżeli nie zostanie podane inaczej, liczna procesów równa jest liczbie rdzeni przydzielonych w ramach węzła. Składnia liczna_węzłów:liczba_rdzeni_na_węźleliczba_procesów.
#QCG nodes=10:5:1
#QCG nodes=12:12
|
walltime
- walltime - dyrektywa definiująca deklarowany przez użytkownika czas wykonania zadania w formacie PnYnMnDTnHnMnS, w formacie ISO 8601 gdzie:
- P - obowiązkowy znak rozpoczynający definicję okresu,
- nY - liczba lat,
- nM - liczba miesięcy,
- nD - liczba dni,
- T - separator czasu (musi być obecny, jeśli zdefiniowane są poniższe wartości)
- nH - liczba godzin,
- nM - liczba minut,
- nS - liczba sekund.
memory
properties
preprocess
postprocess
monitor
monitor - dyrektywa umożliwiająca zdefiniowanie skryptu, który zostanie uruchomiony przed uruchomieniem właściwego zadania i zabity po zakończeniu zadania. Funkcjonalność ta umożliwia w prosty sposób zaimplementowanie monitoringu aplikacji. Uruchomiony skrypt może cyklicznie wyszukiwać w wyniku aplikacji zadanych wzorców i przesyłać je w dowony sposób do użytkownika.
#QCG monitor=monitor-script.sh
|
Przykładowe opisy
QCG-JobProfile
QCG-JobProfile jest XMLowym językiem opisu zadań QCG umożliwiającym dostęp do całej funkcjonalności oferowanej przez usługi QCG.
Język opisu zadań QCG składa się z następujących elementów:
- qcgJob- element grupujący zadania w logiczny eksperyment
- description - opis eksperymentu obliczeniowego
- task- definicja pojedynczego zadania
qcgJob - definicja eksperymentu
Opis każdego eksperymentu obliczeniowego QCG rozpoczyna się elementem qcgJob W elemencie tym można podać następujące atrybuty:
- appId - definiowany przez użytkownika element, który pojawi się jako część identyfikatora eksperymentu. Dozwolone są znaki dopuszczalne w nazwach katalogów w systemie Linux (obowiązkowy, typ: tekst),
- project - identyfikator grantu, w ramach którego zlecany jest eksperyment (opcjonalny, typ: tekst),
commitWait- atrybut określający czy przetwarzanie eksperymentu ma być wstrzymane do czasu aż użytkownik wywoła polecenie commit_job (opcjonalny, dopuszczalne wartości: true,false, wartość domyślna: false),
<qcgJob appId="moj_eksperyment" project="grant123" commitWait="true">
...
</qcgJob>
|
Każdy eksperyment obliczeniowy składa się z minimum jednego zadania - elementu task o unikalnym identyfikatorze.
<qcgJob appId="moj_eksperyment" project="grant123" commitWait="true">
<task taskId="zadanie_1">
...
</task>
<task taskId="zadanie_2">
...
</task>
</qcgJob>
|
description - opis eksperymentu
Eksperyment może zawierać opisujący go opcjonalny element description.
<qcgJob appId="moj_eksperyment">
<description>Najważniejszy eksperyment w PL-Grid<description>
</qcgJob>
|
task - definicja zadania
Element task odpowiada pojedynczemu zadaniu obliczeniowemu wchodzącemu w skład eksperymentu (qcgJob).
Task może/musi zawierać następujące atrybuty:
- taskId - unikalny identyfikator zadania w ramach eksperymentu. Dozwolone są znaki dopuszczalne w nazwach katalogów w systemie Linux (obowiązkowy, typ: tekst)
- persistent - określa czy po zakończeniu zadania system ma automatycznie usunąć czy pozostawić katalog, w którym wykonywało się zadanie (opcjonalny, dopuszczalne wartości: true,false, wartość domyślna: false),
- crucial - określa czy poprawne zakończenie zadania jest istotne dla pomyślnego zakończenia całego eksperymentu (opcjonalny, dopuszczalne wartości: true,false, wartość domyślna: true),
- commitWait - atrybut określający czy przetwarzanie zadania ma być wstrzymane do czasu aż użytkownik wywoła polecenie commit_task (opcjonalny, dopuszczalne wartości: true,false, wartość domyślna: false),
<qcgJob appId="moj_eksperyment">
...
<task taskId="zadanie_2" persistent="true" commitWait="false">
...
</task>
|
description - opis zadania
Zadanie może zawierać opisujący go opcjonalny element description.
<task taskId="zadanie_2" persistent="true" commitWait="false">
<description>Zadanie wyznaczające ...</description>
</task>
|
candidateHosts - lista potencjalnych zasobów obliczeniowych
Zlecając eksperyment do wykonania można dla każdego zadnia zdefiniować listę potencjalnych maszyn, spośród których QCG-Broker będzie dokonywał wyboru. W przypadku braku elementu candidateHosts Broker wybiera spośród wszystkich dostępnych maszyn, na których użytkownik ma prawo wykonywać zadania.
<candidateHosts>
<hostName>reef.man.poznan.pl</hostName>
<hostName>zeus.cyfronet.pl</hostName>
</candidateHosts>
|
requirements - definicja wymagań zasobowych dla zadania
Element ten pozwala na wyrażenie wymagań zasobowych dotyczących zleconego zadania. Możliwe jest zdefiniowanie prostych wymagań opisujące tylko parametry węzłów obliczeniowych (element resourceRequirements) lub, w przypadku zadań rozproszonych, topologii i wymagań dla poszczególnych grup procesów (element topology).
resourceRequirements - opis wymagań zasobowych
Element zawierający opis wymagań zasobowych dotyczący parametrów maszyny obliczeniowej. Element ten może zawierać jeden lub więcej elementów computingResource ze zdefiniowaną listą parametrów - elementy hostParameter. Element hostParameter ma atrybut computingParameterName określający po nazwie definiowany parametr. Wartość parametru może być liczbowa, przekazywana w elemencie value, lub tekstowa w elemencie stringValue.
Lista możliwych parametrów:
- osname - nazwa systemu operacyjnego,
- ostype - typ systemu operacyjnego,
- cpuarch - architektura procesora
- cpucount - liczba procesorów
- gpucount - liczba akceleratorów graficznych
- application - dostępne aplikacje
- queue - nazwa kolejki, do której ma być zlecone zadanie
<requirements>
<resourceRequirements>
<computingResource>
<hostParameter name="gcpucount">
<value>3</value>
</hostParameter>
</computingResource>
</resourceRequirements>
</requirements>
|
<requirements>
<resourceRequirements>
<computingResource>
<hostParameter name="queue">
<stringValue value="plgrid-long"/>
</hostParameter>
</computingResource>
</resourceRequirements>
</requirements>
|
<requirements>
<resourceRequirements>
<computingResource>
<hostParameter name="application">
<stringValue value="abinit"/>
</hostParameter>
</computingResource>
</resourceRequirements>
</requirements>
|
topology - topologia grup procesów
Element topology służy do opisu zadań rozproszonych składających się z potencjalnie wielu grup procesów o odmiennych wymaganiach zasobowych.
W przypadku zadań z wieloma grupami procesów, lub przy podziale grupy pomiędzy wiele zasobów, QCG-Broker dokonuje koalokacji zasobów dla wszystkich grup.
Element topology zawiera nie mniej niż jeden element processes definiujący pojedynczą grupę procesów.
Element processes ma następujące atrybuty:
- processesId - identyfikator grupy procesów (opcjonalny, typ: tekst),
- masterGroup - atrybut ten pozwala określić, do której grupy należeć ma proces master rozproszonej aplikacji (opcjonalny, typ: logiczny, domyślnie false). W przypadku, gdy żadna grupa nie jest wybrana proces master wybierany jest niedeterministycznie,
- divisible - atrybut określający czy dana grupa może być dzielona pomiędzy wiele zasobów (opcjonalny, typ: logiczny, domyślna wartość: true),
Każdy element processes może zawierać następujące elementy: - processesCount - liczność grupy procesów,
- processesMap - mapa alokacji procesów dla zadań hybrydowych (określa liczbę węzłów obliczeniowych dla zadania oraz procesów na każdym z węzłów),
- candidateHosts - lista potencjalnych maszyn, na których może być wykonana grupa procesów,
- reservation - rezerwacja, w ramach której ma być uruchomiona grupa procesów. Element ten wymaga jednoznacznego wyboru maszyny poprzez candidateHosts,
resourceRequirements - opis wymagań zasobowych dla grupy procesów,
<topology>
<processes processesId="SMC:collector:distributor:Blob:voxelizer:thrombusMapper" masterGroup="true">
<processesCount>
<value>1</value>
</processesCount>
<candidateHosts>
<hostName>reef.man.poznan.pl</hostName>
</candidateHosts>
</processes>
<processes processesId="BF">
<processesCount>
<value>32</value>
</processesCount>
<candidateHosts>
<hostName>huygens.sara.nl</hostName>
</candidateHosts>
<reservation type="LOCAL">p6012.huygens.sara.nl.537.r</reservation>
</processes>
<processes processesId="DD">
<processesCount>
<value>4</value>
</processesCount>
<candidateHosts>
<hostName>zeus.cyfronet.pl</hostName>
</candidateHosts>
</processes>
</topology>
|
W poniższym przykładzie zadanie uruchomione zostanie na 3 węzłach (liczba elementów processesPerNode), na każdym węźle do zadania przydzielone zostanie 8 slotów obliczeniowych (atrybut slotsPerNode). Na węzłach uruchomione zostaną odpowiednio 1, 8, 8 procesów (wartości elementu processesPerNode).
<topology>
<processes processesId="process">
<processesMap slotsPerNode="8">
<processesPerNode>1</processesPerNode>
<processesPerNode>8</processesPerNode>
<processesPerNode>8</processesPerNode>
</processesMap>
<candidateHosts>
<hostName>grass1.man.poznan.pl</hostName>
</candidateHosts>
</processes>
</topology>
|
execution - deklaracja typu zadania
Element execution opisuje uruchomienie pojedynczego zadania. Zawiera informację jaki jest jego typ, plik wykonywalny, argumenty, strumienie wejścia, wyjścia i błędów, pliki i katalogi z danymi wejściowymi i wynikami oraz zmienne środowiskowe. Atrybut type określa rodzaj zadania oraz sposób w jaki będzie wykonywane. Wspierane są następujące typy:
- single - aplikacja będąca pojedynczym procesem,
- open_mpi, mpi_mp - zadanie rozproszone MPI. Zadanie może składać się z wielu alokacji, a stan zadania zależy od stanu wszystkich alokacji. Jeżeli element stdout/etderr wskazuje na katalog, to standardowe wyjścia zgrywane są ze wszystkich alokacji. Jeżeli element stdout/etderr wskazuje na plik, to standardowe wyjścia zgrywane jest tylko z procesu mastera. Pliki wyjściowe kopiowane są tylko z głównej alokacji (proces master). W przypadku, gdy jedna z alokacji zakończy się niepowodzeniem, wykonywanie pozostałych jest automatycznie anulowane. Ustawiane są następujące zmienne środowiskowe:
- OMPI_SESSION_ID - unikalny identyfikator sesji,
- OMPI_PROCESSES_ID - identyfikator grupy procesów,
- OMPI_MASTER_GROUP - informacja czy dana alokacja zawiera proces master,
- OMPI_PROCESSES - łaczna liczba procesów,
- OMPI_COLORS - opis kolorów dla zadania (procesy o tym samym kolorze znajdują się na tym samym zasobie),
- QCG_MACHINEFILE - lokalizacja pliku machinefile,
- mapper - zadanie rozproszone. Różni się od typu open_mpi tym, że pliki wyjściowe przegrywane są ze wszystkich alokacji. Dla tego typu zadnia przekazywane są następujące zmienne środowiskowe: OMPI_PROCESSES_ID, OMPI_MASTER_GROUP, OMPI_PROCESSES,
- proactive - zadanie rozproszone środowiska PROACTIVE. Różni się od zadania open_mpi tym, że do głównej alokacji kopiowany jest tworzony automatycznie plik proactive description. Do zadania przekazywane są następujące zmienne środowiskowe:
- PROACITIVE_SESSION_ID - identyfikator sesji, mający postać '{JOBID}:{TASKID}'
- PROACTIVE_PROCESSES_ID - identyfikator grupy procesów
- PROACTIVE_MASTER_GROUP - informacja czy dana alokacja zawiera proces master,
- PROACTIVE_PROCESSES - łączna liczba procesów.
<execution type="single">
...
</execution>
|
executable - deklaracja aplikacji lub pliku wykonywalnego
Element określający aplikację oraz jej wersję (element application) lub plik wykonywalny (element execFile) dla danego zadania.
<executable>
<application name="abinit" version="6.10.1"/>
</executable>
|
<executable>
<execFile>
<file>
<location type="URL">file:////usr/bin/cal</location>
</file>
</execFile>
</executable>
|
<executable>
<execFile>
<file>
<location type="URL">gsiftp://qcg.man.poznan.pl/~/executable</location>
</file>
</execFile>
</executable>
|
arguments - argumenty zadnia
Lista argumentów dla uruchomienia aplikacji. Każdy argument powinien być podany jako osobna wartość.
<arguments>
<value>argument_1</value>
<value>argument_2</value>
<value>argument_3</value>
</arguments>
|
stdin - standardowe wejście
Element stdin umożliwia przypisanie pliku do standardowego wejścia procesu. Element stdin musi zawierać lokalizację pojedynczego pliku. Wspierane są następujące typy lokalizacji:
stdout - standardowe wyjście
Element stdout pozwala zdefiniować, gdzie powinno zostać przegrane standardowe wyjście aplikacji. Plik ten przegrywany jest jednokrotnie po zakończeniu wykonywania aplikacji. Element stdout może zawierać lokalizację pojedynczego pliku (element file), lub w przypadku aplikacji rozproszonej wykonującej się na wielu zasobach lokalizację katalogu (element directory), do którego przegrane zostaną pliki ze standardowym wyjściem z każdej alokacji.
Wspierane są następujące typy lokalizacji:
stderr - standardowe wyjście błędów
Element stderr pozwala zdefiniować, gdzie powinno zostać przegrane standardowe wyjście błędów aplikacji. Plik ten przegrywany jest jednokrotnie po zakończeniu wykonywania aplikacji. Element stderr może zawierać lokalizację pojedynczego pliku (element file), lub w przypadku aplikacji rozproszonej wykonującej się na wielu zasobach lokalizację katalogu (element directory), do którego przegrane zostaną pliki ze standardowym wyjściem błędu z każdej alokacji.
Wspierane są następujące typy lokalizacji:
stageInOut - deklaracja danych wejściowych/wyjściowych
Element stdInOut umożliwia zarządzanie danymi (plikami i katalogami) wejściowymi i wyjściowymi aplikacji. Element ten musi zawierać co najmniej jeden element opisujący plik (element file) lub katalog (element directory). Elementy file i directory muszą zawierać lokalizacje odpowiednio pojedynczego pliku lub katalogu i mają następujący zbiór atrybutów:
environment - zmienne środowiskowe
Lista zmiennych środowiskowych i ich wartości, które przekazane zostaną przy uruchomieniu zadania
<environment>
<variable name="PATH">/home/piontek</variable>
<variable name="VERBOSE">true</variable>
</environment>
|
reservation - rezerwacje
Element reservation pozwala zdefiniować rezerwację, do której ma być zlecone zadanie.
Element posiada atrybuty:
- type - typ rezerwacji
- QCG - identyfikator rezerwacji założonej przez QCG-Broker,
- LOCAL - identyfikator rezerwacji założonej bezpośrednio w systemie kolejkowym.
- processGroupId - identyfikator grupy procesów, dla której rezerwacja została założona. Istotne w przypadku, gdy rezerwacja założona została dla zadania z grupami procesów.
executionTime - wymagania czasowe
Element executionTime pozwala zdefiniować wymagania czasowe dla zadania. Element ten musi zawierać element executionDuration definiujący długość czasu obliczeń oraz opcjonalnie element timePeriod określający okno czasowe, w którym zadanie ma być wykonane. Element timePeriod musi zawierać element periodStart określający początek okna czasowego oraz periodEnd (koniec okna) lub periodDuration (długość okna czasowego).
<executionTime>
<executionDuration>P0Y0M0DT0H30M</executionDuration>
</executionTime>
|
<executionTime>
<executionDuration>P0Y0M0DT24H0M</executionDuration>
<timePeriod>
<periodStart>2011-11-23T14:29:00</periodStart>
<periodEnd>2011-11-24T18:29:00</periodEnd>
</timePeriod>
</executionTime>
|
workflow - definicja zależności kolejnościowych zadań
Element workflow pozwala definiować złożone zależności kolejnościowe pomiędzy zadaniami w eksperymencie. Dla każdego zadania możliwe jest zdefiniowanie od jakich innych zadań ono zależy, używając zagnieżdżonych warunków z wykorzystaniem operatorów AND/OR oraz dowolnych stanów zadań. Zależności pomiędzy zadaniami nie mogą zawierać cykli. Element workflow może zawierać jeden z następujących elementów:
parameterSweep - definicja zmienności parametrów
Element parameterSweep służy do definiowania zadań parametrycznych, to znaczy takich, w których ta sama aplikacja uruchamiana jest wielokrotnie dla różnych parametrów. QCG-Broker umożliwia definiowanie wielowymiarowej przestrzeni parametrów, w której jednocześnie wg podanych reguł może zmienianych być wiele parametrów. Możliwe jest definiowanie różnych schematów zmienności parametrów (kolejności zmieniania wartości wielu parametrów) jak również zakresów zmienności pojedynczych elementów. Element parameterSweep musi zawierać co najmniej jeden element parameter definiujący zmienność pojedynczego parametru. Element parameter zawiera następujące elementy:
- name - nazwa parametru,
- value - element definiujące zmienność parametru. Zawiera jeden z elementów:
<parametersSweep>
<parameter>
<name>arg1</name>
<value>
<loop>
<start>0</start>
<end>9</end>
<step>1</step>
<except>
<value>3</value>
<value>6</value>
</except>
</loop>
</value>
</parameter>
</parametersSweep>
|
| task | arg1 |
|---|
| task_1 | 1 |
| task_2 | 2 |
| task_3 | 3 |
| task_4 | 4 |
| task_5 | 5 |
| task_6 | 6 |
| task_7 | 7 |
| task_8 | 8 |
| task_9 | 9 |
<parametersSweep>
<parameter>
<name>arg2</name>
<value>
<set>
<item>a</item>
<item>b</item>
</set>
</value>
</parameter>
</parametersSweep> |
<parametersSweep>
<parameter>
<name>arg1</name>
<value>
<loop>
<start>0</start>
<end>5</end>
<step>1</step>
<except>
<value>3</value>
<value>4</value>
</except>
</loop>
</value>
</parameter>
<parameter>
<name>arg2</name>
<value>
<set>
<item>a</item>
<item>b</item>
</set>
</value>
</parameter>
</parametersSweep> |
| task | arg1 | arg2 |
|---|
| task_1 | 0 | a |
| task_2 | 1 | b |
| task_3 | 2 | a |
| task_4 | 5 | b |
<parametersSweep>
<parameter>
<name>arg1</name>
<value>
<loop>
<start>0</start>
<end>5</end>
<step>1</step>
<except>
<value>3</value>
<value>4</value>
</except>
</loop>
</value>
<parameter>
<name>arg2</name>
<value>
<set>
<item>a</item>
<item>b</item>
</set>
</value>
</parameter>
</parameter>
</parametersSweep> |
| task | arg1 | arg2 |
|---|
| task_1 | 0 | a |
| task_2 | 0 | b |
| task_3 | 1 | a |
| task_4 | 1 | b |
| task_5 | 2 | a |
| task_6 | 2 | b |
| task_7 | 5 | a |
| task_8 | 5 | b |
Przykładowe opisy eksperymentów
EKSPERYMENT: Pobranie pliku report, spakowanie go aplikacją tar i przegranie wyniku do podanej lokalizacji. Zadanie wykonane zostanie na klastrze reef.man.poznan.pl. Standardowe strumienie wyjścia przegrane zostaną do podanych lokalizacji.
<grmsJob appId="eksperyment">
<task taskId="tar">
<candidateHosts>
<hostName>reef.man.poznan.pl</hostName>
</candidateHosts>
<execution type="single">
<executable>
<execFile>
<file>
<location type="URL">file:////bin/tar</location>
</file>
</execFile>
</executable>
<arguments>
<value>cfv</value>
<value>report.tar</value>
<value>report</value>
</arguments>
<stdout>
<file>
<location type="URL">gsiftp://qcg.man.poznan.pl/~stdout-${JOB_ID}</location>
</file>
</stdout>
<stderr>
<file>
<location type="URL">gsiftp://qcg.man.poznan.pl/~/stderr-${JOB_ID}</location>
</file>
</stderr>
<stageInOut>
<file name="report" type="in">
<location type="URL">gsiftp://fury.man.poznan.pl/~/examples/report</location>
</file>
<file name="report.tar" type="out">
<location type="URL">gsiftp://fury.man.poznan.pl/~/examples/report.tar</location>
</file>
</stageInOut>
</execution>
</task>
</grmsJob> |
Eksperyment: Wykonanie zbioru zadań „calc” dla miesięcy roku 2012 z pominięciem miesięcy 3 i 6. Standardowe lokalizacje przegrane zostaną do podanej lokalizacji.
<grmsJob appId="kalendarze">
<task taskId="calendar">
<execution type="single">
<executable>
<execFile>
<file>
<location type="URL">file:////usr/bin/cal</location>
</file>
</execFile>
</executable>
<arguments>
<value>${PS_month}</value>
<value>2012</value>
</arguments>
<stdout>
<file>
<location type="URL">${TASK_DIR}/stdout.txt</location>
</file>
</stdout>
</execution>
<parametersSweep>
<parameter>
<name>month</name>
<value>
<loop>
<start>1</start>
<end>12</end>
<step>1</step>
<except>
<value>3</value>
<value>6</value>
</except>
</loop>
</value>
</parameter>
</parametersSweep>
</task>
</grmsJob> |
Eksperyment: Prosty workflow składający się z dwóch zadań (aplikacja date). Drugie zadanie wykonane będzie po zakończeniu pierwszego. Strumienie wyjściowe przegrane zostaną do podanych lokalizacji.
<qcgJob appId="example1">
<task taskId="date_1">
<execution type="single">
<executable>
<execFile>
<file>
<location type="URL">file:////bin/date</location>
</file>
</execFile>
</executable>
<stdout>
<file>
<location type="URL">gsiftp://qcg.man.poznan.pl/~/date-${JOB_ID}-${TASK_ID}.txt</location>
</file>
</stdout>
</execution>
</task>
<task taskId="date_2">
<execution type="single">
<executable>
<execFile>
<file>
<location type="URL">file:////bin/date</location>
</file>
</execFile>
</executable>
<stdout>
<file>
<location type="URL">gsiftp://qcg.man.poznan.pl/~/date-${JOB_ID}-${TASK_ID}.txt</location>
</file>
</stdout>
</execution>
<workflow>
<parent triggerState="FINISHED">date_1</parent>
</workflow>
</task>
</qcgJob> |
Eksperyment: Prosty workflow, w którym drugie zadanie „pakuje” wyjście polecenia „ps” w pierwszego zadania. Plik przekazywane są „przez” referencje.
<qcgJob appId="ps_tar">
<task taskId="ps">
<execution type="single">
<executable>
<execFile>
<file>
<location type="URL">file:////bin/ps</location>
</file>
</execFile>
</executable>
<arguments>
<value>aux</value>
</arguments>
<stdout>
<file>
<location type="REFERENCE">ref1</location>
</file>
</stdout>
</execution>
</task>
<task taskId="tar">
<execution type="single">
<executable>
<execFile>
<file>
<location type="URL">file:////bin/tar</location>
</file>
</execFile>
</executable>
<arguments>
<value>czf</value>
<value>ps.tgz</value>
<value>ps</value>
</arguments>
<stageInOut>
<file name="ps" type="in">
<location type="REFERENCE">ref1</location>
</file>
<file name="ps.tgz" type="out">
<location type="URL">gsiftp://qcg.reef.man.poznan.pl/ps.tgz</location>
</file>
</stageInOut>
</execution>
<workflow>
<parent triggerState="FINISHED">ps</parent>
</workflow>
</task>
</qcgJob> |
Wersje klienta tekstowego
SimpleClient
QCG-SimpleClient oferuje prosty, wzorowany na poleceniech systemu kolejkowego, interfejs do infrastruktury QCG.
Polecenia
