Method and apparatus for obtaining status information in a grid

• US 7,716,061 B2
• Filed: 03/27/2003
• Issued: 05/11/2010
• Est. Priority Date: 03/27/2003
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Keohane, Susann Marie, McBrearty, Gerald Francis, Shieh, Johnny Meng-Han, Murillo, Jessica Kelley, Mullen, Shawn Patrick
• Primary Examiner(s): OUELLETTE, JONATHAN P
• Application Number:
  US10/401,323
• Publication Number:
  US 20040193461A1
• Time in Patent Office: 2,602 Days
• Field of Search: 705/1
• US Class Current: 705/1.1
• CPC Class Codes: G06Q 10/06 Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling

Abstract

The present invention provides a method, apparatus, and computer instructions for obtaining status information for processes executing in a grid. Responsive to a submission of a job from the data processing system to a remote node on the grid, a job identifier is received from the remote node. The job identifier is saved in a set of job identifiers. Responsive to a request for a status of jobs submitted from the data processing system, a job status request for each job identifier in the set of job identifiers for processes still executing is submitted using the set of job identifiers to form a set of job status requests. Responses to the set of job status requests are received. The responses are then presented.

Claims

1. A method in a data processing system for obtaining status information for processes executing in a grid, the method comprising:

receiving, by a local node, a first command, wherein the first command is a globus-job-submit command enclosed in a wrapper, and wherein the globus-job-submit command is for submitting a plurality of jobs to be processed;

creating, by the wrapper, a directory in the local node;

receiving, by a grid resource application management (GRAM) service node, the plurality of jobs to be processed;

distributing, by the GRAM service node, the plurality of jobs to a plurality of remote nodes to execute the plurality of jobs;

returning, to the local node by the globus-job-submit command, a return string that includes a particular job identifier and a particular host name for each one of the plurality of jobs being executed by each one of the plurality of remote nodes, wherein the particular host name identifies one of the plurality of remote nodes that is executing a particular job identified by the particular job identifier;

reading, by the wrapper from the return string, the particular job identifier and the particular host name for each one of the plurality of jobs; and

storing, by the wrapper, the particular job identifier and the particular host name for each one of the plurality of jobs in a separate file in the directory.

2. The method of claim 1, wherein each job identifier is a unique identifier.

3. The method of claim 1, wherein the status of each one of the plurality of jobs is presented using at least one of a display screen and a speaker.

4. The method of claim 1, wherein the job identifier for each one of the plurality of jobs is received in a string that was created by a globus job manager.

5. The method of claim 1, wherein the return string is a return resource specification definition language (RSL) string.

6. The method of claim 1, wherein the globus-job-submit command is a Globus Toolkit command.

7. The method of claim 1, wherein the globus-job-submit command is a batch interface and is submitted to the GRAM service node from the local node.

8. The method of claim 1, wherein the wrapper is initiated only in response to the receipt of the first command by the local node, and wherein the globus-job-submit command does not cause the wrapper to perform the creating, reading, and storing.

9. The method of claim 1, wherein the first command includes the globus-job-submit command and the wrapper.

10. The method of claim 1, wherein the globus-job-submit command is included in a wrapper routine.

11. The method of claim 1, further comprising:

while each one of the plurality of jobs is still being executed, submitting a third UNIX command to obtain a current status of each one of the plurality of jobs;

reading, by the third UNIX command, each file in the directory;

for each file in the directory;

issuing, by the third UNIX command, a remote job to one of the plurality of remote nodes identified by a specific host name identified in the file to obtain a current status about a specific one of the plurality of jobs identified in the file, wherein the one of the plurality of remote nodes is processing the specific one of the plurality of jobs.

12. The method of claim 11 further comprising:

removing a job identifier from the directory for a completed one of the plurality of jobs if a current status of the completed one of the plurality of jobs indicates that the completed one of the plurality of jobs is done.

13. The method of claim 11, wherein the third UNIX command is generated in response to at least one of a user input and a periodic event.

14. The method of claim 11, further comprising:

presenting the current status of each specific one of the plurality of jobs identified in each file in the directory.

15. The method of claim 11, wherein the third UNIX command is a process status “

ps”

UNIX command.

16. A data processing system for obtaining status information for processes executing in a grid, the data processing system comprising:

a local node receiving a first command, wherein the first command is a globus-job-submit command enclosed in a wrapper, wherein the globus-job-submit command is for submitting a plurality of jobs to be processed;

a processor executing the wrapper to create a directory in the local node;

a grid resource application management (GRAM) service node receiving the plurality of jobs to be processed;

the GRAM service node distributing the plurality of jobs to a plurality of remote nodes to execute the plurality of jobs;

the local node receiving a return string, from the globus-job-submit command, that includes a particular job identifier and a particular host name for each one of the plurality of jobs being executed by each one of the plurality of remote nodes, wherein the particular host name identifies one of the plurality of remote nodes that is executing a particular job identified by the particular job identifier;

the processor executing the wrapper to read from the return string the particular job identifier and the particular host name for each one of the plurality of jobs; and

the processor executing the wrapper to store the particular job identifier and the particular host name for each one of the plurality of jobs in a separate file in the directory.

17. The data processing system of claim 16, wherein the globus-job-submit command is a batch interface and is submitted to the GRAM service node from the local node.

18. The data processing system of claim 16, wherein the wrapper is initiated only in response to the receipt of the first command by the local node, and wherein the globus-job-submit command does not cause the wrapper to perform the creating, reading, and storing.

19. The data processing system of claim 16, wherein the first command includes the globus-job-submit command and the wrapper.

20. The data processing system of claim 16, wherein the globus-job-submit command is included in a wrapper routine.

21. A computer program product that is stored in a computer-recordable medium and executed by a processor for obtaining status information for processes executing in a grid, the computer program product comprising:

computer usable program code for receiving, by a local node, a first command, wherein the first command is a globus-job-submit command enclosed in a wrapper, wherein the globus-job-submit command is for submitting a plurality of jobs to be processed;

computer usable program code for creating, by the wrapper, a directory in the local node;

computer usable program code for receiving, by a grid resource application management (GRAM) service node, the plurality of jobs to be processed;

computer usable program code for distributing, by the GRAM service node, the plurality of jobs to a plurality of remote nodes to execute the plurality of jobs;

computer usable program code for returning, to the local node by the globus-job-submit command, a return string that includes a particular job identifier and a particular host name for each one of the plurality of jobs being executed by each one of the plurality of remote nodes, wherein the particular host name identifies one of the plurality of remote nodes that is executing a particular job identified by the particular job identifier;

computer usable program code for reading, by the wrapper from the return string, the particular job identifier and the particular host name for each one of the plurality of jobs; and

computer usable program code for storing, by the wrapper, the particular job identifier and the particular host name for each one of the plurality of jobs in a separate file in the directory.

22. The computer program product of claim 21, further comprising:

computer usable program code for submitting a third UNIX command to obtain a current status of each one of the plurality of jobs while each one of the plurality of jobs is still being executed;

computer usable program code for reading, by the third UNIX command, each file in the directory;

for each file in the directory;

computer usable program code for issuing, by the third UNIX command, a remote job to one of the plurality of remote nodes identified by a specific host name identified in the file to obtain a current status about a specific one of the plurality of jobs identified in the file, wherein the one of the plurality of remote nodes is processing the specific one of the plurality of jobs.

23. The computer program product of claim 22, further comprising:

computer usable program code for presenting the current status of each specific one of the plurality of jobs identified in each file in the directory.

24. The computer program product of claim 22 further comprising:

computer usable program code for removing a job identifier from the directory for a completed one of the plurality of jobs if a current status of the completed one of the plurality of jobs indicates that the completed one of the plurality of jobs is done.

25. The computer program product of claim 21, wherein the status of each one of the plurality of jobs is presented using at least one of a display screen and a speaker.

26. The computer program product of claim 21, wherein the job identifier for each one of the plurality of jobs is received in a string that was created by a globus job manager.

27. The computer program product of claim 21, wherein the return string is a return resource specification definition language (RSL) string.

28. The computer program product of claim 21, wherein the globus-job-submit command is a Globus Toolkit command.

29. The computer program product of claim 21, wherein the globus-job-submit command is a batch interface and is submitted to the GRAM service node from the local node.

30. The computer program product of claim 21, wherein the wrapper is initiated only in response to the receipt of the first command by the local node, and wherein the globus-job-submit command does not cause the wrapper to perform the creating, reading, and storing.

31. The computer program product of claim 21, wherein the first command includes the globus-job-submit command and the wrapper.

32. The computer program product of claim 21, wherein the globus-job-submit command is included in a wrapper routine.