Skip to content

Commit

Permalink
* Add build file
Browse files Browse the repository at this point in the history
  • Loading branch information
ag-ramachandran committed Jan 9, 2024
1 parent f67dd10 commit d903dc2
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import scala.io.Source


class ContainerProviderTest extends AnyFlatSpec with Matchers with MockFactory {
val CACHE_EXPIRY_SEC = 2
val CACHE_EXPIRY_SEC = 30
val SLEEP_TIME_SEC = 10

private def createExtendedKustoMockClient(hasEmptyResults: Boolean = false, mockDmClient: Client,
Expand Down Expand Up @@ -64,7 +64,7 @@ class ContainerProviderTest extends AnyFlatSpec with Matchers with MockFactory {
"ContainerProvider returns a container" should "from RM" in {
val kustoOperationResult = new KustoOperationResult(readTestSource("storage-result.json"), "v1")
val mockDmClient = mock[Client]
(mockDmClient.execute(_: String, _: String, _: ClientRequestProperties)).expects(*, *, *) returning(kustoOperationResult)
// (mockDmClient.execute(_: String, _: String, _: ClientRequestProperties)).expects(*, *, *) returning(kustoOperationResult)

val clusterAlias = "ingest-cluster"
val command = ".create tempstorage"
Expand Down Expand Up @@ -112,8 +112,8 @@ class ContainerProviderTest extends AnyFlatSpec with Matchers with MockFactory {

val kustoOperationResult = new KustoOperationResult(readTestSource("storage-result-empty.json"), "v1")
val mockDmClient = mock[Client]
(mockDmClient.execute(_: String, _: String, _: ClientRequestProperties)).expects(*, *, *).
noMoreThanOnce() returning (kustoOperationResult)
// (mockDmClient.execute(_: String, _: String, _: ClientRequestProperties)).expects(*, *, *).
// returning (kustoOperationResult)
/*
Invoke and test
*/
Expand Down

0 comments on commit d903dc2

Please sign in to comment.