in Twitter/Connector/Controllers/DataIngestionController.cs [38:60]
public async Task<HttpResponseMessage> ScheduleTask([FromBody] ScheduleTaskRequest request)
{
Trace.TraceInformation($"Request came to Web for JobId: {request.JobId} and TaskId: {request.TaskId}");
PageJobEntity entity = await GetJobIdFromTable(request.JobId);
if (entity == null)
{
return new HttpResponseMessage(HttpStatusCode.NotFound);
}
else
{
await queueProvider.InsertMessageAsync(JsonConvert.SerializeObject(new ConnectorTask
{
TenantId = Settings.TenantId,
JobId = request.JobId,
TaskId = request.TaskId,
StartTime = request.StartTime,
EndTime = request.EndTime,
DirtyEntities = request.DirtyEntities,
BlobSasUri = request.BlobSasUri
}));
return new HttpResponseMessage(HttpStatusCode.OK);
}
}