Skip to content

Commit 6fd25fa

Browse files
authored
Get starttask logs and fix start-task for docker configuration (#312)
1 parent 62bb7eb commit 6fd25fa

File tree

2 files changed

+122
-88
lines changed

2 files changed

+122
-88
lines changed

src/TesApi.Tests/BatchSchedulerTests.cs

+23-15
Original file line numberDiff line numberDiff line change
@@ -351,14 +351,22 @@ public async Task TesTaskRemainsQueuedWhenBatchQuotaIsTemporarilyUnavailable()
351351
[TestMethod]
352352
public async Task BatchTaskResourcesIncludeDownloadAndUploadScripts()
353353
{
354+
var expectedFiles = new List<string>
355+
{
356+
"batch_script",
357+
"TesTask.json",
358+
"starttask_uploadlogs.json",
359+
"tRunner",
360+
};
361+
354362
(_, var cloudTask, _, _) = await ProcessTesTaskAndGetBatchJobArgumentsAsync(true);
355363

356-
Assert.AreEqual(5, cloudTask.ResourceFiles.Count);
357-
Assert.IsTrue(cloudTask.ResourceFiles.Any(f => f.FilePath.Equals("batch_script")));
358-
Assert.IsTrue(cloudTask.ResourceFiles.Any(f => f.FilePath.Equals("upload_files_script")));
359-
Assert.IsTrue(cloudTask.ResourceFiles.Any(f => f.FilePath.Equals("download_files_script")));
360-
Assert.IsTrue(cloudTask.ResourceFiles.Any(f => f.FilePath.Equals("upload_metrics_script")));
361-
Assert.IsTrue(cloudTask.ResourceFiles.Any(f => f.FilePath.Equals("tRunner")));
364+
foreach (var file in expectedFiles)
365+
{
366+
Assert.IsTrue(cloudTask.ResourceFiles.Any(f => f.FilePath.Equals(file)));
367+
}
368+
369+
Assert.AreEqual(expectedFiles.Count, cloudTask.ResourceFiles.Count);
362370
}
363371

364372
private async Task AddBatchTaskHandlesExceptions(TesState newState, Func<AzureProxyReturnValues, (Action<IServiceCollection>, Action<Mock<IAzureProxy>>)> testArranger, Action<TesTask, IEnumerable<(LogLevel, Exception)>> resultValidator)
@@ -1678,15 +1686,15 @@ private static Action<Mock<IAzureProxy>> GetMockAzureProxy(AzureProxyReturnValue
16781686
var config = Enumerable.Empty<(string Key, string Value)>()
16791687
.Append(("Storage:DefaultAccountName", "defaultstorageaccount"))
16801688
.Append(("BatchScheduling:Prefix", "hostname"))
1681-
//.Append(("BatchImageGen1:Offer", "ubuntu-server-container"))
1682-
//.Append(("BatchImageGen1:Publisher", "microsoft-azure-batch"))
1683-
//.Append(("BatchImageGen1:Sku", "20-04-lts"))
1684-
//.Append(("BatchImageGen1:Version", "latest"))
1689+
.Append(("BatchImageGen1:Offer", "ubuntu-server-container"))
1690+
.Append(("BatchImageGen1:Publisher", "microsoft-azure-batch"))
1691+
.Append(("BatchImageGen1:Sku", "20-04-lts"))
1692+
.Append(("BatchImageGen1:Version", "latest"))
16851693
.Append(("BatchImageGen1:NodeAgentSkuId", "batch.node.ubuntu 20.04"))
1686-
//.Append(("BatchImageGen2:Offer", "ubuntu-hpc"))
1687-
//.Append(("BatchImageGen2:Publisher", "microsoft-dsvm"))
1688-
//.Append(("BatchImageGen2:Sku", "2004"))
1689-
//.Append(("BatchImageGen2:Version", "latest"))
1694+
.Append(("BatchImageGen2:Offer", "ubuntu-hpc"))
1695+
.Append(("BatchImageGen2:Publisher", "microsoft-dsvm"))
1696+
.Append(("BatchImageGen2:Sku", "2004"))
1697+
.Append(("BatchImageGen2:Version", "latest"))
16901698
.Append(("BatchImageGen2:NodeAgentSkuId", "batch.node.ubuntu 20.04"));
16911699
if (autopool)
16921700
{
@@ -1698,7 +1706,7 @@ private static Action<Mock<IAzureProxy>> GetMockAzureProxy(AzureProxyReturnValue
16981706

16991707
private static IEnumerable<FileToDownload> GetFilesToDownload(Mock<IAzureProxy> azureProxy)
17001708
{
1701-
var downloadFilesScriptContent = (string)azureProxy.Invocations.FirstOrDefault(i => i.Method.Name == nameof(IAzureProxy.UploadBlobAsync) && i.Arguments[0].ToString().Contains("/download_files_script"))?.Arguments[1];
1709+
var downloadFilesScriptContent = (string)azureProxy.Invocations.FirstOrDefault(i => i.Method.Name == nameof(IAzureProxy.UploadBlobAsync) && i.Arguments[0].ToString().Contains("/TesTask.json"))?.Arguments[1];
17021710

17031711
if (string.IsNullOrEmpty(downloadFilesScriptContent))
17041712
{

0 commit comments

Comments
 (0)