Hi,
Through my testing, it has no problem, please check your codes:
C:\Users\azureuser\Desktop>hpctest
JobStateCallback: Job state is Submitted
JobStateCallback: Job state is Validating
TaskStateCallback: State for task 57017.1 is Queued
JobStateCallback: Job state is Queued
JobStateCallback: Job state is Running
TaskStateCallback: State for task 57017.1 is Dispatching
TaskStateCallback: State for task 57017.1 is Running
TaskStateCallback: State for task 57017.1 is Finished
Output from task:
Pinging 127.0.0.1 with 32 bytes of data:
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Reply from 127.0.0.1: bytes=32 time<1ms TTL=128
Ping statistics for 127.0.0.1:
Packets: Sent = 10, Received = 10, Lost = 0 (0% loss),
Approximate round trip times in milli-seconds:
Minimum = 0ms, Maximum = 0ms, Average = 0ms
JobStateCallback: Job state is Finished
Press Enter to quit
The codes are as below:
namespace Creating_and_Submitting_a_Job
{
class Program
{
private static ManualResetEvent manualEvent = new ManualResetEvent(false);
static void Main(string[] args)
{
IScheduler scheduler = new Scheduler();
ISchedulerJob job = null;
ISchedulerTask task = null;
try
{
scheduler.Connect("localhost");
// Create a job and add a task to the job.
job = scheduler.CreateJob();
task = job.CreateTask();
task.CommandLine = "ping 127.0.0.1 -n 10";
job.AddTask(task);
// Specify the events that you want to receive.
job.OnJobState += JobStateCallback;
job.OnTaskState += TaskStateCallback;
// Start the job.
scheduler.SubmitJob(job, @"hpc\azureuser", null);
// Blocks so the events get delivered. One of your event
// handlers need to set this event.
manualEvent.WaitOne();
Console.Write("\nPress Enter to quit");
Console.ReadLine();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}
// Add the code from the Implementing the Event Handlers for Job Events in C# topic here.
// Implements the delegates for the SchedulerJob events
private static void JobStateCallback(object sender, IJobStateEventArg args)
{
IScheduler scheduler = null;
ISchedulerJob job = null;
Console.WriteLine("JobStateCallback: Job state is " + args.NewState);
if (JobState.Canceled == args.NewState ||
JobState.Failed == args.NewState ||
JobState.Finished == args.NewState)
{
manualEvent.Set();
}
else
{
try
{
scheduler = (IScheduler)sender;
job = scheduler.OpenJob(args.JobId);
// TODO: Do something with the job
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}
}
private static void TaskStateCallback(object sender, ITaskStateEventArg args)
{
IScheduler scheduler = null;
ISchedulerJob job = null;
ISchedulerTask task = null;
Console.WriteLine("TaskStateCallback: State for task {0} is {1}", args.TaskId.ToString(), args.NewState);
if (TaskState.Finished == args.NewState ||
TaskState.Failed == args.NewState)
{
try
{
scheduler = (IScheduler)sender;
job = scheduler.OpenJob(args.JobId);
task = job.OpenTask(args.TaskId);
Console.WriteLine("Output from task:\n" + task.Output);
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}
}
}
}
Qiufang Shi
