Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Ensemble Model Connections Improvement #732

Merged
merged 3 commits into from
Aug 9, 2018

Conversation

wangcj05
Copy link
Collaborator

@wangcj05 wangcj05 commented Aug 4, 2018


Pull Request Description

What issue does this change request address? (Use "#" before the issue to link it, i.e., #42.)

close #696

What are the significant changes in functionality due to this change request?

For Change Control Board: Change Request Review

The following review must be completed by an authorized member of the Change Control Board.

  • 1. Review all computer code.
  • 2. If any changes occur to the input syntax, there must be an accompanying change to the user manual and xsd schema. If the input syntax change deprecates existing input files, a conversion script needs to be added (see Conversion Scripts).
  • 3. Make sure the Python code and commenting standards are respected (camelBack, etc.) - See on the wiki for details.
  • 4. Automated Tests should pass, including run_tests, pylint, manual building and xsd tests. If there are changes to Simulation.py or JobHandler.py the qsub tests must pass.
  • 5. If significant functionality is added, there must be tests added to check this. Tests should cover all possible options. Multiple short tests are preferred over one large test. If new development on the internal JobHandler parallel system is performed, a cluster test must be added setting, in XML block, the node <internalParallel> to True.
  • 6. If the change modifies or adds a requirement or a requirement based test case, the Change Control Board's Chair or designee also needs to approve the change. The requirements and the requirements test shall be in sync.
  • 7. The merge request must reference an issue. If the issue is closed, the issue close checklist shall be done.
  • 8. If an analytic test is changed/added is the the analytic documentation updated/added?

@wangcj05 wangcj05 requested a review from alfoa August 4, 2018 20:51
@alfoa
Copy link
Collaborator

alfoa commented Aug 4, 2018

I already reviewed a PR like this... where did it end up?

graphDict = copy.deepcopy(self.__graphDict)
# Extend graph dictionary generated by ensemble model to graph theory acceptable dictionary
# Basicly, if a -> b (a is connected to b), the self.__graphDict = {'a':['b'], 'b':[]}
# Since a is connected to b, from the graph theory, the dictionary should become {'a':['b'], 'b':['a']}
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This class was supposed to represent a directed graph since was mainly used by the ensemble model for the identification of the execution order.
Please, put a WARNING to avoid to store this extended graph dictionary in __graphDict and specify that this should be used for the isConnected method only.

In addition, enhance the comment above (and in the above docstrings) to state this.

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fixed.

# NEEDS TO BE THREAD-SAFE!!!!!
# IN CASE IT IS NOT, THE USER NEEDS TO SET A LOCK SYSTEM!!!!!
import threading
localLock = threading.RLock()
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

you do not need the lock here (for this model). Please remove it and remove the comment above. In addition all the above imports are not used.

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

removed.

localLock = threading.RLock()

def initialize(self, runInfo, inputs):
pass
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

it is not needed... if it is not present, it will not be called.

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

removed.

pass

def run(self, Input):
self.C = self.A + self.B
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

add docstrings to describe what this model is used for

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

removed

localLock = threading.RLock()

def initialize(self, runInfo, inputs):
pass
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

same comments I reported for model alpha.py

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

removed

pass

def run(self, Input):
self.F = self.E + 1.0
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

same comments i reported for the other 2 models

Copy link
Collaborator Author

@wangcj05 wangcj05 Aug 6, 2018

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fixed.

pass

def run(self, Input):
self.G = self.H + 3.0
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

as above

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fixed

pass

def run(self, Input):
self.D = self.G + 1.0
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

as above

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fixed

pass

def run(self, Input):
self.I = self.D - 1.0
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

as above

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fixed

[./testEMConnection]
type = 'RavenFramework'
input = 'test_em_connection.xml'
output = 'checkConnection/1-plotData_scatter.png'
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

either you check the plot with an Image Checker or you dump a csv for comparing with a gold file.

Second option is the preferred one (in case, remove the plot that it will be useless)

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fixed.

@moosebuild
Copy link

Job Mingw Test on be29bcb : invalidated by @wangcj05

test time out

@wangcj05
Copy link
Collaborator Author

wangcj05 commented Aug 9, 2018

@alfoa This is ready for you to review.

Copy link
Collaborator

@alfoa alfoa left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Comments addressed...

@alfoa
Copy link
Collaborator

alfoa commented Aug 9, 2018


For Change Control Board: Change Request Review

The following review must be completed by an authorized member of the Change Control Board.

  • 1. Review all computer code. done
  • 2. If any changes occur to the input syntax, there must be an accompanying change to the user manual and xsd schema. If the input syntax change deprecates existing input files, a conversion script needs to be added (see Conversion Scripts). done
  • 3. Make sure the Python code and commenting standards are respected (camelBack, etc.) - See on the wiki for details. done
  • 4. Automated Tests should pass, including run_tests, pylint, manual building and xsd tests. If there are changes to Simulation.py or JobHandler.py the qsub tests must pass. they pass
  • 5. If significant functionality is added, there must be tests added to check this. Tests should cover all possible options. Multiple short tests are preferred over one large test. If new development on the internal JobHandler parallel system is performed, a cluster test must be added setting, in XML block, the node <internalParallel> to True. ok
  • 6. If the change modifies or adds a requirement or a requirement based test case, the Change Control Board's Chair or designee also needs to approve the change. The requirements and the requirements test shall be in sync. n/a
  • 7. The merge request must reference an issue. If the issue is closed, the issue close checklist shall be done. The connected net check in the ensemble model can return false even if the model are connected #696
  • 8. If an analytic test is changed/added is the the analytic documentation updated/added? n/a

@alfoa
Copy link
Collaborator

alfoa commented Aug 9, 2018

Checklist passed...

Merging...

@alfoa alfoa merged commit 02ba132 into idaholab:devel Aug 9, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

The connected net check in the ensemble model can return false even if the model are connected
3 participants