public async Task ScheduleTask()

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);
            }
        }