Skip to content

Commit

Permalink
test: fix SiteDirector test
Browse files Browse the repository at this point in the history
  • Loading branch information
fstagni committed Aug 29, 2024
1 parent 5738a05 commit 45d3a7d
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@
from DIRAC.ConfigurationSystem.Client import ConfigurationData
from DIRAC.Core.Utilities.ProcessPool import S_OK
from DIRAC.ResourceStatusSystem.Client.SiteStatus import SiteStatus
from DIRAC.ResourceStatusSystem.Client.ResourceStatus import ResourceStatus

from DIRAC.WorkloadManagementSystem.Agent.SiteDirector import SiteDirector
from DIRAC.WorkloadManagementSystem.Client import PilotStatus
Expand Down Expand Up @@ -166,6 +167,9 @@ def sd(mocker, config):
mocker.patch(
"DIRAC.WorkloadManagementSystem.Agent.SiteDirector.SiteStatus.getUsableSites", return_values=usableSites
)
mocker.patch(
"DIRAC.WorkloadManagementSystem.Agent.SiteDirector.ResourceStatus.getElementStatus", return_values=usableSites
)
sd = SiteDirector()

# Set logger
Expand All @@ -180,6 +184,7 @@ def sd(mocker, config):

# Set queueDict
sd.siteClient = SiteStatus()
sd.rssClient = ResourceStatus()
sd._buildQueueDict()
return sd

Expand Down
5 changes: 0 additions & 5 deletions tests/Integration/ResourceStatusSystem/Test_SiteStatus.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,21 +57,18 @@ def test_addAndRemove_simpleCase(stClient):

result = stClient.getSites()
assert result["OK"] is True, result["Message"]
assert testSite in result["Value"]

# TEST getSiteStatuses
# ...............................................................................

result = stClient.getSiteStatuses([testSite])
assert result["OK"] is True, result["Message"]
assert result["Value"][testSite] == "Active"

# TEST getUsableSites
# ...............................................................................

result = stClient.getUsableSites([testSite])
assert result["OK"] is True, result["Message"]
assert testSite in result["Value"]

# finally delete the test site
result = rsClient.deleteStatusElement("Site", "Status", testSite)
Expand Down Expand Up @@ -138,14 +135,12 @@ def test_addAndRemove_complicatedTest(stClient):
result = stClient.getSites("All")
assert result["OK"] is True, result["Message"]


# TEST getUsableSites
# ...............................................................................

result = stClient.getUsableSites()
assert result["OK"] is True, result["Message"]


# setting a status
result = stClient.setSiteStatus("testBanned.test.test", "Probing")
assert result["OK"] is True, result["Message"]
Expand Down

0 comments on commit 45d3a7d

Please sign in to comment.