Date: Fri, 29 Mar 2024 13:25:35 +0000 (UTC) Message-ID: <352643016.12965.1711718735296@change.sos-berlin.com> Subject: Exported From Confluence MIME-Version: 1.0 Content-Type: multipart/related; boundary="----=_Part_12964_566523452.1711718735296" ------=_Part_12964_566523452.1711718735296 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Content-Location: file:///C:/exported.html
<?xml version=3D"1.0" encoding=3D"ISO-8859-1"?> <job order=3D"yes"> <params> <param name=3D"ParallelExecution_required_orders" value=3D"2"/&g= t; <param name=3D"ParallelSample_required_orders" value=3D"1"/&g= t; </params> <script language=3D"java" java_class=3D"sos.scheduler.job.JobSchedulerSynchronizeJobChain= s"/> <run_time/> </job>
/SampleParallel=
/ParallelExecution
.
<?xml version=3D"1.0" encoding=3D"ISO-8859-1"?> <job order=3D"yes"> <params> <param name=3D"job_chain" value=3D"/SampleParallel/ParallelExec= ution"/> </params> <script language=3D"javascript"><![CDATA[ =09=09function spooler_process() { =09=09 =09var actOrder =3D spooler_task.order; =09=09=09var order =3D spooler.create_order(); =09=09=09var job_chain =3D spooler.job_chain( spooler_task.params.value(= "job_chain" ) ); =09=09=09order.state =3D actOrder.state; =09=09=09order.params.merge(actOrder.params); =09=09=09order.id =3D order.state + ":" + actOrder.id; =09=09=09job_chain.add_or_replace_order(order); =20 =09=09=09return true; =09=09} ]]></script> <monitor name=3D"configuration_monitor" ordering=3D"0"> <script java_class=3D"sos.scheduler.managed.configuration.Config= urationOrderMonitor" language=3D"java" java_class_path=3D""/> </monitor> <run_time/> </job>
<?xml version=3D"1.0" encoding=3D"ISO-8859-1"?> <job_chain orders_recoverable=3D"yes"> <job_chain_node state=3D"p1" job=3D"ParallelJob1" next_state=3D"p1.b" error_state=3D"error"/> <job_chain_node state=3D"p1.b" job=3D"aJob" next_state=3D"sync" error_state=3D"error"/> <job_chain_node state=3D"p2" job=3D"ParallelJob2" next_state=3D"sync" error_state=3D"error"/> <job_chain_node state=3D"sync" job=3D"Sync" next_state=3D"success" error_state=3D"error"/> <job_chain_node state=3D"success"/> <job_chain_node state=3D"error"/> </job_chain>
<?xml version=3D"1.0" encoding=3D"ISO-8859-1"?> <job_chain orders_recoverable=3D"yes" visible=3D"yes"> <job_chain_node state=3D"100" job=3D"anyJobBefore" next_state=3D"p1" error_state=3D"error"/> <job_chain_node state=3D"p1" job=3D"execute" next_state=3D"p2" error_state=3D"error"/> <job_chain_node state=3D"p2" job=3D"execute" next_state=3D"sync" error_state=3D"sync"/> <job_chain_node state=3D"sync" job=3D"Sync" next_state=3D"200" error_state=3D"error"/> <job_chain_node state=3D"200" job=3D"anyJobAfter" next_state=3D"success" error_state=3D"error"/> <job_chain_node state=3D"success"/> <job_chain_node state=3D"error"/> </job_chain>
Add an order for the job chain ParallelSample. You can assign a=
schedule for this order.
<?xml version=3D"1.0" encoding=3D"ISO-8859-1"?> <order> <run_time> <period single_start=3D"10:00"/> </run_time> </order>
You can download the source for this example from here.